java - ConnectableObservable 何时终止？

Question

我有一个可观察的对象，它可以发挥一些魔力，并且我将它用作 Activity 范围中的单例。因此，想要获取更新的人可以订阅并获得最后的排放值和新的排放量。

Observable<Object> currentZoneObservable;

    public Observable<Object> getCurrentZoneObservable() {
        if (currentZoneObservable == null) {
            currentZoneObservable = someUseCase.getObservable()
            .replay(1)
            .autoConnect();
        }
        return currentZoneObservable;
    }

我确保所有这些订阅者都以良好公民的身份取消订阅。我什至计算了 doOnSubsbscribe() 和 doOnUnSubscribe() 中的订阅者数量。当应用程序进入后台时，它有 0 个订阅者。

我的问题是 connectableObservable 永远不会完成，如果它正在执行某些操作，它仍然会继续执行。例如。如果在网络不可用时重试某些网络调用，它会继续这样做。

如何确保我的 connectableObservable 在没有订阅者时停止？我的理解是 .autoConnect() 应该处理这个问题。

Answer 1

autoConnect()当不再有观察者时不再取消订阅 - refCount()确实如此。

您可能有兴趣使用 BehaviorSubject :一些不错的文档

• Intro to Rx doc
• Mindorks doc