android - 在后台使用而不是在 Activity/Fragment 中使用时如何在 RxJava2 中处理单个观察者

Question

当在后台而不是在 Activity/Fragment 中使用时，如何在 RxJava2 中处理 Single observer。

我知道如果 Single 在 Activity/Fragment 中使用，那么它可以添加到复合处理程序中并在 Activity/Fragment 的 onDestroy 方法中处理它。

但是当它被其他地方调用时如何处理它呢？

如果 Single 从 Activity/Fragment 调用并且我们想在 onDestroy 被调用之前处理它，还有什么其他方法可以处理它？<​​/p>

Answer 1

由 ConsumerSingleObserver 返回的两个默认观察者( BiConsumerSingleObserver 和 Single )当你subscribe自行处置onError和 onSuccess .如果您传入自己的自定义 SingleObserver ，您需要决定何时处置它。

A Single will call only one of these methods, and will only call it once. Upon calling either method, the Single terminates and the subscription to it ends. (http://reactivex.io/documentation/single.html)

在某些情况下，您可能希望处理 SingleObserver在它自行处理之前，在这种情况下你只需要调用 dispose在 Disposable 上由 subscribe 返回.您调用它的时间和地点实际上取决于您的具体情况。

如果您的 Single在您的生命周期对象被销毁(例如 HTTP 调用)之前没有完成，您必须将观察者放置在生命周期对象的销毁回调中。