RxJava 等待一个可观察的订阅者等待另一个可观察的与其他订阅者

Question

我有这个问题，我一直在寻找，但找不到解决方案（或者也许我不能根据其他答案做出解决方案）。

我的问题是，我需要找到一种方法来等待可观察的（有自己的订户）并等待另一个可观察的（有自己的订户）完成。

场景是这样的:

奥布1-

奥布斯2 -

我主要担心的是我需要两个订阅者。在我看来，obs1 和 obs2 并行运行，但需要检查 obs1 是否以新的会话令牌完成。也许这不是RxJava的主要目的。

Obs1连接到一个HTTP连接并获取一个Json，其中包含要填充UI的数据，而obs2相同，但包含其他json和其他信息来填充UI。

对我来说，唯一的问题是我的会话令牌每5分钟到期一次，当我尝试获取新的令牌时，我已经使用过期的会话令牌进行了调用。

简单的解决方案是在on complete()subscribe 1中执行obs2，但我知道使用RxJava是更好的解决方案。

Answer 1

看看zip，它将允许您组合两个可观察量的结果（如果需要，可以并行运行）。下面是一个示例：

obs1.subscribeOn(Schedulers.io())
    .zipWith(obs2.subscribeOn(Schedulers.io()), (x,y) -> new Both(x,y))
    .doOnNext(both -> updateUI(both))
    .subscribe();