In RxJava 1 gab es CompositeSubscription, aber das ist in RxJava2 nicht vorhanden. In rxJava2 gibt es etwas CompositeDisposable. Wie verwende ich CompositeDisposable oder Disposable in RxJava2?
77
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 erstellt, um die Verwendung von RxJava2 zu demonstrieren. Hier finden Sie das Beispielprojekt - RxJava2-Android-Samples
CompositeDisposable
kann nach der Entsorgung nicht wiederverwendet werden. Wenn Sie den Einweg-Lebenszyklus mit dem Android-Aktivitätslebenszyklus synchronisieren möchten, können Sie dies durch Erstellen eines einfachen Wrappers tun.class AndroidDisposable { private var compositeDisposable: CompositeDisposable? = null fun add(disposable: Disposable) { if (compositeDisposable == null) { compositeDisposable = CompositeDisposable() } compositeDisposable?.add(disposable) } fun dispose() { compositeDisposable?.dispose() compositeDisposable = null } }
Wie benutzt man:
class MainActivity : AppCompatActivity() { private disposable = AndroidDisposable() override fun onStart() { super.onStart() disposable.add(/* Some disposable */) } override fun onStop() { disposable.dispose() super.onStop() } }
quelle
// clearing or unsubscibing disposables.clear();
diesen Ort nutzen
dispose()
quelle