作用
跟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
弄混了
总结
这个系列只有干货,如果大家有什么好的建议的话欢迎在下面评论。或者觉得我哪里写的不够形象了,同样可以提出来。