作者:呜呀002_107_284 | 来源:互联网 | 2023-09-23 19:27
如您所引用的文档中所述-
合并可以交错输出,而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;)
文档提供了漂亮的图形来显示差异。您需要记住,合并不能 保证 逐项交错,这只是可能的例子之一。