RxJava 2-可观察。flatMapSingle澄清

Question

我做了一个RxJava2实验，包括以下步骤：

1. 从对象列表创建一个可观察对象。
2. 使用EquiMapSing（）将可观察对象发出的每个项目映射到SingleSource。在平图单（）中，对可观察对象发出的每个项目执行异步操作。
3. 收集ListB中的所有项目，使用Observable.toList（）

结果：由于异步操作，ListB的项目顺序与ListA不同。

因此，flatMapSingle（）的工作原理似乎与flatMap（）类似，因为它使用了merge操作符，并且不能保证元素的顺序将得到保留。

我的结论正确吗？文档没有涵盖我，关于这种行为的讨论也不存在。

Answer 1

flatMap不能保证按照评论中提到的@akarnokd订购。

如果您想保证排序，可以使用concatMap，但它只允许您与内部可观察的连接。RxJava1和RxJava2中似乎都没有concatMapSingle的版本。但是，您可以通过自己使用toObservable（）将内部单个转换为可观察的来解决此问题，并将其与以下concatMap一起使用（用Kotlin编写的代码）。

Observable
    .fromIterable(listA)
    .concatMap { single.toObservable() }
    .toList() // Items in the list has same order of listA

请注意，还有一个concatmapagenger，它将急切地订阅一个内部的可观察的（或上例中的单个），这可能有助于改进并行化任务。