java - RXJava2。我是否需要处理一次发出的流？ (单例，也许)

Question

我的代码中有很多Single，比如

Disposable disp = Single.fromCallable(()-> loadData())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe(res-> showInUI(res),
                    throwable -> Log.e(TAG, throwable.getMessage()))
            );

正如我从文档中了解到的，Observable 和 Single 之间的区别在于 Single 可以响应错误、从不响应、响应成功并且它只发出一次。现在我不在任何地方处置，一切正常。

那么我是否需要执行 disp.dispose() 呢？

Answer 1

是的，的确，是Single/Observable/Completable都没有关系。
这很重要，因为您不想让您的 UI 绑定(bind)到某些后台工作，这会泄漏您的 Activity。
这也很重要，因为您不希望在某个时间点(例如，在您的 Activity 销毁之后)在 UI 上收到通知，这可能会导致 NPE 或其他问题。除此之外，当用户离开/关闭 Activity/Screen 时，取消和停止昂贵的后台工作是一个很好的做法，以清除资源。
所有这些注意事项对于所有 Observable 类型都是通用的。