Rx Observable onCompleted 在处理后调用

Question

我在我的 Android 应用程序中使用 RxJava2。我有一个Observable，它在创建时被添加到CompositeDisposable。此Observable 正在从某些 API 检索数据，可能需要很长时间才能完成。

当我在下载时离开页面时，在onPause 中，我正在处理这个CompositeDisposable，但有时仍会调用Observable 的onComplete。

怎么会这样？

Answer 1

如 Doc 中所述，onTerminateDetach 取消了对上游生产者和下游的引用。

例如

mDisposable.add(
            apiClient.apiCallSomeAPI()
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .concatMap(this::responseObservable)           
                    .toList()
                    .onTerminateDetach() // this is important, exactly before subscribe
                    .doOnSuccess(this::realmBulkOperation)
                    .subscribe(this::handleResult, this::handleError)
    );