Join FlipAndroid.COM Telegram Group: https://t.me/joinchat/F_aqThGkhwcLzmI49vKAiw


Cómo utilizar CompositeDisposable de RxJava 2?

Ejemplos sobre cómo usar CompositeDisposable o Desechable en RxJava2. En RxJava 1, hubo CompositeSubscription, pero que no está presente en RxJava2, Hay algo CompositeDisposable en rxJava2. Cómo utilizar CompositeDisposable o Desechable en RxJava2.

2 Solutions collect form web for “Cómo utilizar CompositeDisposable de RxJava 2?”

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(); 

Tengo un proyecto de crear un ejemplo para demostrar el uso de RxJava2. Aquí puede encontrar el proyecto de ejemplo – RxJava2-Android-Samples

 // clearing or unsubscibing disposables.clear(); 

Este lugar use dispose()

FlipAndroid es un fan de Google para Android, Todo sobre Android Phones, Android Wear, Android Dev y Aplicaciones para Android Aplicaciones.