我有一个ConnectableObservable
和多个订阅者。并且订阅通过使用运算符在不同的线程中进行subscribeOn
。
问题是我想在所有订阅完成后调用connect
运营商,因为我不希望任何订阅者错过任何数据包。
但是我无法确定是否所有订阅者都订阅了可观察量,因为它发生在不同的线程上。
我也不想使用replay
运算符。没有理由仅仅因为异步订阅而缓存所有数据包。
如果您知道Subscriber
的确切数量,并且您唯一想要的操作是在所有都准备就绪时进行连接,请使用 autoConnect(int)
.