RxJava2操作符之“Concat”与“ConcatArray”
RxJava2操作符之“Concat”与“ConcatArray”
坑吭吭
发布于 2018-08-31 17:29:07
发布于 2018-08-31 17:29:07
作用
跟Merge操作符很像，但是这个操作符是能保证输出顺序的
Concat：
emit the emissions from two or more Observables without interleaving them 从两个或更多的被观察者中发送事件，而且还能保证输出顺序（将两个被观察者合并成一个）
ConcatArray：
将数组中的被观察者合并成一个整体，并且保证发送顺序
示例用法
final String[] aStrings = {"A1", "A2", "A3", "A4"};
final String[] bStrings = {"B1", "B2", "B3"};
final Observable<String> aObservable = Observable.fromArray(aStrings);
final Observable<String> bObservable = Observable.fromArray(bStrings);
Observable.concat(aObservable, bObservable)//使用concat操作符将两个被观察者合并
.subscribe(getObserver());//这里的观察者依然不重要为了方便介绍ConactArray的用法，这里贴一段源码就明白了：
public static <T> Observable<T> concat(ObservableSource<? extends T> source1, ObservableSource<? extends T> source2) {
return concatArray(source1, source2);//conat的内部其实是调用的`concatArray`方法
}而concatArray的方法为：
public static <T> Observable<T> concatArray(ObservableSource<? extends T>... sources)里面可以传多个Observable进去。
运行结果
"A1", "A2", "A3", "A4","B1", "B2", "B3"
分析
我们创建了两个被观察者，两个里面分别有不同的，很明显属于两个被观察者的一些事件。 其中： A打头的都属于第一个被观察者 B打头的都属于第二个被观察者
然后用操作符concat将两个被观察者合并
最后，他会发射出所有的7个在列表中的事件
过程：先发射第一个Observable里面所有的事件，然后发射第二个
注意
再啰嗦一遍，这里要注意conact和conactArray之后的Observable保证和原来的Observable发射顺序相同,千万不要和merge弄混了
总结
这个系列只有干货，如果大家有什么好的建议的话欢迎在下面评论。或者觉得我哪里写的不够形象了，同样可以提出来。
本文参与 腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2017.03.31 ，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
目录