RxJava2操作符之“Concat”与“ConcatArray”

2019年6月5日 414次阅读 来源: 坑吭吭

作用

跟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弄混了

总结

这个系列只有干货，如果大家有什么好的建议的话欢迎在下面评论。或者觉得我哪里写的不够形象了，同样可以提出来。

    原文作者：坑吭吭
    原文地址: https://www.jianshu.com/p/95f8f9d76ac6
    本文转自网络文章，转载此文章仅为分享知识，如有侵权，请联系博主进行删除。
点赞