Concat VS合并运算符

Question

我查看了RXJava的文档，发现concat和merge运算符似乎也做同样的事情。我写了几次测试来确定。

@Test
public void testContact() {

    Observable.concat(Observable.just("Hello"),
                      Observable.just("reactive"),
                      Observable.just("world"))
              .subscribe(System.out::println);
}

@Test
public void testMerge() {

    Observable.merge(Observable.just("Hello"),
                      Observable.just("reactive"),
                      Observable.just("world"))
            .subscribe(System.out::println);
}

该文件说

合并运算符也类似。它结合了两个或多个可观察物的排放，但可以交错，而Concat绝不会交错多个可观察物的排放。

但是我还是不太了解，运行此测试数千次，合并结果始终是相同的。由于未授予该命令，因此我期望有时会出现“反应性”，“世界”，“你好”。

代码在这里https://github.com/politrons/reactive

Answer 1

如您所引用的文档中所述-
合并可以交错输出，而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;）

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

康卡特

合并