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

作用

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里面所有的事件,然后发射第二个

注意

再啰嗦一遍,这里要注意conactconactArray之后的Observable保证和原来的Observable发射顺序相同,千万不要和merge弄混了

总结

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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 本篇文章介主要绍RxJava中操作符是以函数作为基本单位,与响应式编程作为结合使用的,对什么是操作、操作符都有哪些...
    嘎啦果安卓兽阅读 2,899评论 0 10
  • 注:只包含标准包中的操作符,用于个人学习及备忘参考博客:http://blog.csdn.net/maplejaw...
    小白要超神阅读 2,250评论 2 8
  • 作者: maplejaw本篇只解析标准包中的操作符。对于扩展包,由于使用率较低,如有需求,请读者自行查阅文档。 创...
    maplejaw_阅读 45,857评论 8 93
  • 创建操作 用于创建Observable的操作符Create通过调用观察者的方法从头创建一个ObservableEm...
    rkua阅读 1,873评论 0 1
  • 参考:给 Android 开发者的 RxJava 详解-扔物线深入浅出RxJava 基础 "a library f...
    Vincen1024阅读 548评论 0 1