【发布时间】：2019-12-02 19:20:51
【问题描述】：
想象有一个 Observable A 发射
a1, a2, a3, a4...
A.flatMap(a -> f(a)) 会以不可预知的顺序发出项目，例如：
fa3, fa1, fa2, fa4...
我怎样才能得到如下顺序的结果？
fa1, fa2, fa3, fa4...
ConcatMap可以返回我想要的结果，但是它是按顺序处理流的，在耗时方面效果不佳。
我需要像 concatMap 这样具有并行处理能力的东西。有什么解决办法吗？谢谢。
【问题讨论】：
-
看
concatMapEager -
@zella 肯定我在寻找什么。您可以将其发布为答案吗？
标签： parallel-processing rx-java2 flatmap concatmap