Learning RxJava - Second Edition

Using CompositeDisposable

If you have several subscriptions that need to be managed and disposed of, it can be helpful to use CompositeDisposable. This implements Disposable, but internally holds a collection of Disposable objects, which you can add to and then dispose of all at once:

import io.reactivex.rxjava3.core.Observable;import io.reactivex.rxjava3.disposables.CompositeDisposable;import io.reactivex.rxjava3.disposables.Disposable;import java.util.concurrent.TimeUnit;public class Ch2_35 {    private static final CompositeDisposable disposables =                                           new CompositeDisposable();    public static void main(String[] args) {        Observable<Long> seconds =                              Observable.interval(1, TimeUnit.SECONDS);        //subscribe and capture disposables Disposable disposable1 ...