java – Concat VS Merge运算符

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了java – Concat VS Merge运算符，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1599字，纯文字阅读大概需要3分钟。

内容图文

我正在检查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);
}

文件说

The Merge operator is also similar. It combines the emissions of two or more Observables, but may interleave them, whereas Concat never interleaves the emissions from multiple Observables.

但是我还是不完全明白,运行这个测试千次,合并结果总是一样的.由于订单未被授予,我期待有时“反应性”“世界”“你好”.

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

解决方法:

它如您所引用的文档中所述 – merge可以交错输出,而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;)

文档提供了很好的图表来显示差异.你需要记住,merge不能保证逐个交错项,这只是一个可能的例子.

CONCAT

合并

内容总结

以上是互联网集市为您收集整理的java – Concat VS Merge运算符全部内容，希望文章能够帮你解决java – Concat VS Merge运算符所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端