Concat VS合并运算符

如您所引用的文档中所述-
合并可以交错输出，而concat将首先等待较早的流完成，然后再处理较晚的流。在您的情况下，对于单元素静态流，它没有任何实际的区别（但从理论上讲，合并可以按随机顺序输出单词，但根据规范仍然有效）。如果您想查看两者之间的区别，请尝试执行以下 *** 作（之后需要添加一些睡眠以避免过早退出）

    Observable.merge( Observable.interval(1, TimeUnit.SECONDS).map(id -> "A" + id), Observable.interval(1, TimeUnit.SECONDS).map(id -> "B" + id))    .subscribe(System.out::println);

A0 B0 A1 B1 B2 A2 B3 A3 B4 A4

与

    Observable.concat( Observable.interval(1, TimeUnit.SECONDS).map(id -> "A" + id), Observable.interval(1, TimeUnit.SECONDS).map(id -> "B" + id))    .subscribe(System.out::println);

A0 A1 A2 A3 A4 A5 A6 A7 A8

Concat永远不会开始打印B，因为流A永远不会结束。

s / stream / observable / g;）

文档提供了漂亮的图形来显示差异。您需要记住，合并不能 保证 逐项交错，这只是可能的例子之一。

康卡特

合并