时间戳

首页 > 解决方案 > 如何实现有序的 Observable.merge()

android - 如何实现有序的 Observable.merge()

问题描述

我必须观察未完成的

val firstObservable = ....
val secondObservable = ...

我想要实现的是这两个 observables 之间的某种有序合并，我已经尝试过

Observable.merge(firstObservable, secondObservable)

但这显然不能保证被保存项目的顺序。首先似乎对我有用的是：

Observable.concatArrayEager(firstObservable, secondObservable)

但由于我的 observables 没有完成 secondObservable 永远没有机会发射项目。我也试过

Observable.concatArrayEager(firstObservable.take(1), secondObservable.take(2))

但这种方法的问题是所有其他排放都被忽略了。有谁知道如何处理这种情况？我想继续从我的 observable 接收物品，但也保持秩序。

Observable.concatArrayEager(firstObservable, secondObservable)

对我来说似乎是一个很好的方向，因为它曾经并行运行我的 observables，性能对我来说也很重要，但我无法让它工作，也无法让 observables 持续发射项目

如果您有任何想法，请告诉我。谢谢！

标签： androidobservablerx-java2

解决方案

推荐阅读