如何在每个像ConnectableObservable这样的热门观察者都完成的时候获得一个回调？

在 RxJava 中，ConnectableObservable 是一种特殊的 Observable 类型，它在被订阅时并不会立即开始发射数据，而是需要手动调用 connect() 方法来触发数据的发射。那么，如何在每个 ConnectableObservable 都完成时获得一个回调呢？

要在每个 ConnectableObservable 完成时获得一个回调，可以使用 doOnComplete() 操作符。doOnComplete() 操作符是一个副作用操作符，它会在 Observable 完成时触发一个回调函数。可以在每个 ConnectableObservable 上调用 doOnComplete()，并在回调函数中执行所需的操作。

以下是示例代码：

ConnectableObservable<String> connectableObservable = Observable.just("data")
        .publish();

// 订阅并触发数据的发射
connectableObservable.connect();

connectableObservable
        .doOnComplete(() -> {
            // 在每个 ConnectableObservable 完成时触发的回调函数
            // 执行所需的操作
            System.out.println("ConnectableObservable completed");
        })
        .subscribe();

在这个例子中，我们首先创建了一个 ConnectableObservable，并在之后调用了 connect() 方法以触发数据的发射。然后，我们在 ConnectableObservable 上调用 doOnComplete()，并在回调函数中输出一条消息。最后，我们订阅这个 ConnectableObservable。

当 ConnectableObservable 完成时，即数据发射完毕后，doOnComplete() 方法中的回调函数会被触发，输出消息 "ConnectableObservable completed"。

总结一下，要在每个 ConnectableObservable 都完成时获得一个回调，可以使用 doOnComplete() 操作符，并在回调函数中执行所需的操作。

更多关于 RxJava 的详细信息，以及腾讯云相关产品和产品介绍链接，请访问腾讯云官方文档：

• RxJava 文档：https://cloud.tencent.com/document/product/266/33479
• 腾讯云产品介绍链接地址：https://cloud.tencent.com/product/266