Làm thế nào để sử dụng CompositeDisposable của RxJava 2?

Question

Ví dụ về cách sử dụng CompositeDisposable hoặc Disposable trong RxJava2. Trong RxJava 1, đã có CompositeSubscription, nhưng đó không phải là hiện diện trong RxJava2, Có một cái gì đó CompositeDisposable trong rxJava2. Cách sử dụng CompositeDisposable hoặc Disposable trong 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(); 

Tôi có một dự án mẫu để minh họa việc sử dụng RxJava2. Ở đây bạn có thể tìm thấy sample project - RxJava2-Android-Samples

Answer 2

// clearing or unsubscibing 
    disposables.clear(); 

nơi này sử dụng dispose()