我正在尝试从服务器调用中积累 Observables，然后将它们平面化并进行另一个服务器调用。
private Observable poll(Observable<TaskStatus> taskObservable) {
Observable.add(taskObservable) //Pseudocode
.buffer(3 sec)
.flatMap(...)
...
}
如何实现Observable累加(“add”)？
最佳答案
您可能正在寻找merge()运算符。
有关组合 Observables 的更多信息，请参阅:https://github.com/Netflix/RxJava/wiki/Combining-Observables
关于java - 累积来自不同流的 Observables 以进行轮询，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/22618164/