如何使用RxJava 2的CompositeDisposable？

Question

在RxJava 1中，有一个叫做CompositeSubscription的类，但是在RxJava2中已不再存在，而它的替代品是rxJava2中的另一个类——CompositeDisposable。那么我该如何使用CompositeDisposable或Disposable呢？

- anand gaurav

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

参考文章

- Amit Shekhar

---

为什么他们取消了订阅？ - anand gaurav

他们从头开始编写了RxJava2，因此创建了更好的API。 - Amit Shekhar

@anandgaurav 订阅现在被流使用并且服务于另一个目的。旧的订阅现在是可处理的。 - loshkin

@amit，你能帮我解决如何使用rx java通过API进行get和post请求吗？我看过你的示例，非常棒。 假设——需要传递baseurl /用户ID和密码作为字符串。 并且在注册时需要使用json对象进行post。 如果我能得到任何帮助，我将不胜感激。只需向我发布具有CompositeDisposable语法的内容即可。 - Chayan Chowdhury

@AmitShekhar 对于 .clear() 和 .dispose() 之间的区别的评论非常好！我不知道使用 dispose() 将不接受任何新的可处理对象。 - Kenny Sexton

Answer 2

CompositeDisposable 在被处理后就无法再次使用。如果您想同步处理 Android Activity 生命周期和 Disposable 生命周期，可以通过创建一个简单的封装器来实现对应。

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
    }
}

如何使用：

class MainActivity : AppCompatActivity() {
    private disposable = AndroidDisposable()

    override fun onStart() {
        super.onStart()
        disposable.add(/* Some disposable */)
    }

    override fun onStop() {
        disposable.dispose()
        super.onStop()
    }
}

- Seroj Grigoryan

Answer 3

// clearing or unsubscibing
  disposables.clear(); 

这个地方使用 dispose()

- 孔维生

---

不建议这样做，因为在调用dispose()后无法重新订阅可观察对象。 - box