确定主题何时没有订阅服务器

Question

我想使用PublishSubject创建一个广播系统，一个后台任务将轮询一些endpoint，并定期使用该主题广播结果。我希望在第一个订阅者订阅主题时开始轮询，并在没有更多订阅者时停止轮询。如果有新订阅者订阅，则应继续轮询。

Answer 1

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

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

使用share()运算符使observable变为ConnectableObservable，它将在第一个观察者订阅它时启动，与后续订阅共享所有发射，并在最后一个观察者取消订阅时自动停止。在这里阅读更多关于它的信息。