android - 合并 2 个 observable 并从第一个完成的 observable 中获取输出

Question

我有一个等待推送通知的订阅和另一个正在轮询服务器以获得响应的订阅。我想一起启动两个 observable 并从第一个完成的那个返回数据。在这里使用什么运算符？

Answer 1

因为你想要第一个完成的数据，你必须把数据放在某个地方，直到你通过将每个数据收集到它自己的列表中并使用 amb 来选择终端事件首先发出事件信号的来源(收集的列表)。然后您可以将列表展开回单个项目。

Observable<A> source1 = ...
Observable<A> source2 = ...

Observable.amb(source1.toList(), source2.toList())
.flatMapIterable(list -> list)
.subscribe(...);