rx java - 确保在调用 ConnectableObservable 上的 connect 之前完成所有订阅



我有一个ConnectableObservable和多个订阅者。并且订阅通过使用运算符在不同的线程中进行subscribeOn

问题是我想在所有订阅完成后调用connect运营商,因为我不希望任何订阅者错过任何数据包。

但是我无法确定是否所有订阅者都订阅了可观察量,因为它发生在不同的线程上。

我也不想使用replay运算符。没有理由仅仅因为异步订阅而缓存所有数据包。

如果您知道Subscriber的确切数量,并且您唯一想要的操作是在所有都准备就绪时进行连接,请使用 autoConnect(int) .

最新更新