前言：

众所周知RxJava是个好东西，至于好在哪里大家相信大家都看过了百度出来的第一篇文章就是 抛物线的这篇文章 《给 Android 开发者的 RxJava 详解》,这篇文章很好，但是像我一样的读得懵懵懂懂得人应该也是大有人在吧，而且是关于RxJava 1.0版本的，现在已经是Rxjava 2.0 时代了，好多东西已经发生了变化，那么我推荐各位看这位大佬 Season_zlc 的文章，写的贼棒，笔者是折服了 ，专题链接：RxJava2.x 。但是笔者认为读了这些还不够，RxJava 还有大量的操作符需要我们进行探索，不太监了，笔者为大家带来关于 RxJava 的各种操作符的相关笔记，共勉，共勉。

正题:

开篇一张图，剩下的全靠编。。。而且图还是盗图 。╮(╯﹏╰）╭

笔者的笔记是基于 RxJava 2.0 入手，不研究源码，因为笔者水平不够，会用就好了嘛，嘿嘿嘿！首先，先引入依赖 : RxJava

implementation 'io.reactivex.rxjava2:rxandroid:2.1.0'
implementation 'io.reactivex.rxjava2:rxjava:2.2.3'

1、create 基本创建符

1)、基础写法

  //创建被观察者
        Observable<Integer> observable = Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {

                logDUtils("observable  onNext:1");
                emitter.onNext(1);
                logDUtils("observable  onNext:2");
                emitter.onNext(2);
                logDUtils("observable  onNext:3");
                emitter.onNext(3);
                logDUtils("observable  onNext:4");
                emitter.onNext(4);

                logDUtils("observable  onComplete");
                emitter.onComplete();

                logDUtils("observable  onNext:5");
                emitter.onNext(5);
            }
        });
        
        //创建观察者
        Observer<Integer> observer = new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                logDUtils("onSubscribe:" + d.toString());
            }

            @Override
            public void onNext(Integer integer) {
                logDUtils("onNext:" + integer);
            }

            @Override
            public void onError(Throwable e) {
                logDUtils("onError:" + e.getMessage());
            }

            @Override
            public void onComplete() {
                logDUtils("onComplete:");
            }
        };
        //进行订阅
        observable.subscribe(observer);

2）、链式调用

    private void createMethod() {
        Observable.create(new ObservableOnSubscribe<Integer>() {
            @Override
            public void subscribe(ObservableEmitter<Integer> emitter) throws Exception {
                //创建被观察对象
                emitter.onNext(1);
                //结束发送
                emitter.onComplete();
            }
        }).subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {

            }

            @Override
            public void onNext(Integer integer) {
            //接收被观察对象发送的 对象
            }

            @Override
            public void onError(Throwable e) {
            //接收 onError 事件 ，做出相应反应
            }

            @Override
            public void onComplete() {
             //事件处理完成，做出相应处理
            }
        });
    }

3）、作用

完整创建1个被观察者对象（Observable）
属于 RxJava 最基本的创建符

2、just 快速创建符

1）、作用

创建1个被观察者对象
直接发送 传入的事件（逐一发送）

最多只能发送 10 个事件

2）、代码

  private void justMethod() {
        Observable.just(1,2,3,4,5).subscribe(new Observer<Integer>() {
            @Override
            public void onSubscribe(Disposable d) {
                logDUtils("onSubscribe:" );
            }

            @Override
            public void onNext(Integer integer) {
                logDUtils("onNext:" + integer);
            }

            @Override
            public void onError(Throwable e) {
                logDUtils("onError:" + e.getMessage());
            }

            @Override
            public void onComplete() {
                logDUtils("onComplete:");
            }
        });

    }

3、fromeArray 发送数组内数据

1)、作用

创建1个被观察者对象
直接发送 传入的数组数据(逐一发送) 相当于遍历

2）、代码

 /**
     * fromArray 操作符
     */
    private void arrayMethod() {

        String str[] = {"AAA", "BBB", "CCC", "DDD"};

        Observable.fromArray(str).subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                logDUtils("onSubscribe:");
            }

            @Override
            public void onNext(String s) {
                logDUtils("onNext:" + s);
            }

            @Override
            public void onError(Throwable e) {
                logDUtils("onError:" + e.getMessage());
            }

            @Override
            public void onComplete() {
                logDUtils("onComplete:");
            }
        });
    }

3）、效果

4、fromIterable 操作符

1)、作用

创建1个被观察者对象
直接发送 传入的集合 List 内数据（相当于遍历）

2）、代码

 /**
     *fromIterable 操作符
     */
    private void listMethod() {
        ArrayList<String> list = new ArrayList<>();
        list.add("111");
        list.add("222");
        list.add("333");
        list.add("444");
        list.add("555");
        Observable.fromIterable(list).subscribe(new Observer<String>() {
            @Override
            public void onSubscribe(Disposable d) {
                logDUtils("onSubscribe:");
            }

            @Override
            public void onNext(String s) {
                logDUtils("onNext:" + s);
            }

            @Override
            public void onError(Throwable e) {
                logDUtils("onError:" + e.getMessage());
            }

            @Override
            public void onComplete() {
                logDUtils("onComplete:");
            }
        });
    }

3)、效果