确定 Subject 何时没有订阅者

Question

我想使用 PublishSubject 创建广播系统，后台任务将轮询某些端点并使用此 Subject 定期广播结果。我想在第一个订阅者订阅主题时开始轮询，并在没有更多订阅者时停止轮询。如果有新订阅者订阅，轮询应该会恢复。

我看到的唯一有点相关的函数是 hasObservers() 但它不太符合我的需要，我想要订阅和取消订阅的回调 - 如果没有说明，我会开始轮询前者，对于后者，如果没有更多订阅者，我将停止投票；这是如何实现的？

Answer 1

你可以围绕一个主题创建一个包装器来保持计数，但听起来你的问题可以用 ConnectableObservable 来解决。考虑一下：

Observable<PollData> pollData = Observable.interval(1, TimeUnit.SECONDS)
                         .flatMap(i -> api.pollData())
                         .share();

使用 share() 运算符使该可观察对象成为 ConnectableObservable，它将在第一个观察者订阅它时启动，与后续订阅共享所有发射，并在最后一个观察者取消订阅时自动停止。阅读更多相关信息 here。

确定 Subject 何时没有订阅者

Determine when Subject has no subscribers

android

rx-java2