如何在RxKotlin/RxJava中取消订阅Flowable？

Question

在这篇文章之后，我正在使用带有RxJava/RxKotlin Flowable的Room。我让它运行，但在带有3个片段的ViewPager中使用它存在问题。

我将向您介绍我的代码：

我有一个带有选项卡布局和三个片段（A、B和收藏夹）的视图分页器。前两个片段包含可以添加到收藏夹的数据列表。

在最喜欢的片段中，我使用Flowable来监听A和B所做的更改并相应地更新列表。但是，当一个项目在A和B中成为最喜欢的项目时，应用程序会崩溃，因为即使片段不在前台，最喜欢的片段中的Flowable订阅也会运行。

我想要的是能够在片段不在前台时停止订阅，并在前台启动。

我试图在收藏夹片段的onPause方法中阻止它，但flowable没有取消订阅或处置方法。

我的代码是

dbRepository?.getAllImportant()?.subscribeOn(Schedulers.io())
            ?.observeOn(AndroidSchedulers.mainThread())
            ?.subscribe(getFlowableSubscriber())

Answer 1

订阅可流动对象时，它会返回一个Dispose对象。如果您在此调用dispose（），您将从disposable中取消订阅。

我看不到您的代码，但如果您无法访问该对象，您还可以在您的Flowable中添加获取直到或获取同时如果您不在视野中。不过，这有点像黑客，因为它不会取消订阅源可观察，直到发出下一个项目并调用获取直到。调用dispose是最好的选择。

Answer 2

谢谢你的回答。我找到了一个解决方法。通过在FlowableSubscriber的onSubscribe（订阅：订阅）函数中保存订阅。然后在onStop（）中调用subscription.cancel

        override fun onSubscribe(subscription: Subscription) {
            log("onSubscribe")
            [e-mail] = subscription
        }

和

    override fun onStop() {
           log("onStop() ")
           this.subscription.cancel()
           super.onStop()
     }

Answer 3

您应该将Flowable包含在复合式Disposable（）中，并在想要取消订阅时使用composite.dipose（）。

CompositeDisposable composite = new CompositeDisposable();

composite.add(dbRepository?.getAllImportant()?.subscribeOn(Schedulers.io())
        ?.observeOn(AndroidSchedulers.mainThread())
        ?.subscribe(getFlowableSubscriber())

然后当您想取消订阅时：

composite.dispose();

通常，您应该在onDestroy或onPause方法中取消订阅Flowable。