java - RxJava 中的 concatMap 和 flatMap 有什么区别

Question

这两个功能似乎很相似。它们具有相同的签名(接受 rx.functions.Func1<? super T, ? extends Observable<? extends R>> func )，并且它们的大理石图看起来完全相同。无法在此处粘贴图片，但这是 concatMap 的一张图片, 这是 flatMap 的一个.对结果 Observable 的描述似乎有一些细微的差别。 , 其中一个由 concatMap 制作包含由连接产生的 Observables 产生的项目，以及由 flatMap 产生的项目。包含首先合并生成的 Observables 并发出合并结果的项目。

但是，我完全不清楚这种微妙之处。谁能更好地解释这种差异，最好举一些例子来说明这种差异。

Answer 1

正如您所写，这两个函数非常相似，细微的差别在于如何创建输出(在应用映射函数之后)。

平面 map 使用merge operator而 concatMap 使用 concat operator .

如您所见，concatMap 输出序列是有序的——第一个 Observable 发出的所有项目都在第二个 Observable 发出的任何项目之前发出，
当 flatMap 输出序列被合并时 - 合并后的 Observable 发出的项目可能以任何顺序出现，无论它们来自哪个源 Observable。