Learning RxJava

Using CompositeDisposable

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

    import io.reactivex.Observable;    import io.reactivex.disposables.CompositeDisposable;    import io.reactivex.disposables.Disposable;    import java.util.concurrent.TimeUnit;    public class Launcher {      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 =          seconds.subscribe(l -> System ...