Wie verwende ich CompositeDisposable von RxJava 2?

Question

Beispiele zur Verwendung von CompositeDisposable oder Disposable in RxJava2. In RxJava 1 gab es CompositeSubscription, aber das ist nicht in RxJava2 vorhanden. Es gibt etwas CompositeDisposable in rxJava2. Verwendung von CompositeDisposable oder Disposable in RxJava2

Answer 1

private final CompositeDisposable disposables = new CompositeDisposable(); 


// adding an Observable to the disposable 
disposables.add(sampleObservable() 
       .subscribeOn(Schedulers.io()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribeWith(new DisposableObserver<String>() { 
        @Override 
        public void onComplete() { 
        } 

        @Override 
        public void onError(Throwable e) { 
        } 

        @Override 
        public void onNext(String value) { 
        } 
       })); 

    static Observable<String> sampleObservable() { 
     return Observable.defer(new Callable<ObservableSource<? extends String>>() { 
      @Override 
      public ObservableSource<? extends String> call() throws Exception { 
       // Do some long running operation 
       SystemClock.sleep(2000); 
       return Observable.just("one", "two", "three", "four", "five"); 
      } 
     }); 
    }     


// Using clear will clear all, but can accept new disposable 
disposables.clear(); 
// Using dispose will clear all and set isDisposed = true, so it will not accept any new disposable 
disposables.dispose(); 

Ich habe ein Beispielprojekt erstellen, um die Verwendung von RxJava2 zu demonstrieren. Hier finden Sie die sample project - RxJava2-Android-Samples

Answer 2

// clearing or unsubscibing 
    disposables.clear(); 

dieser Ort Nutzung dispose()