parallel-processing - Rxjava2如何让flatMap按调用顺序发射项目？

Question

想象有 Observable A 发射

a1, a2, a3, a4...

A.flatMap(a -> f(a))将以不可预知的顺序发出项目，例如：

fa3, fa1, fa2, fa4...

我怎样才能按如下顺序获得结果？

fa1, fa2, fa3, fa4...

ConcatMap可以返回我想要的结果，但是它是按顺序处理流的，在耗时方面效果不佳。我需要像 concatMap 这样具有并行处理能力的东西。有什么解决办法吗？谢谢。

Answer 1

您可以使用concatMapEager, 它缓冲发射并按顺序生成项目。