RxJava学习之旅二 2.0.1版本和1.0简单实用的对比讲解

第一篇用了1.0版本的RxJava 从现在开始来使用2.0.1，还是使用新的好一些

compile 'io.reactivex.rxjava2:rxjava:2.0.1'
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

解释一下其中两个陌生的玩意：ObservableEmitter和Disposable.
ObservableEmitter： Emitter是发射器的意思，那就很好猜了，这个就是用来发出事件的，它可以发出三种类型的事件，通过调用emitter的onNext(T value)、onComplete()和onError(Throwable error)就可以分别发出next事件、complete事件和error事件。

这里使用要注意有使用规则
ObservableEmitter 可以发送无限个onNext,但是complete和onError时间只能发送其中一个

Observer<String> observer = new Observer<String>() {
        @Override
        public void onSubscribe(Disposable d) {

        }

        @Override
        public void onNext(String value) {

        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    };

但是只要在收到onError或者onComplete后就不会再接收onNext,这时候会出现的情况就是被观察的ObservableEmitter反射器可能还会继续发送onNext但是接收这Observer不会再接收onNext时间。

注: 关于onComplete和onError唯一并且互斥这一点, 是需要自行在代码中进行控制, 如果你的代码逻辑中违背了这个规则, 并不一定会导致程序崩溃. 比如发送多个onComplete是可以正常运行的, 依然是收到第一个onComplete就不再接收了, 但若是发送多个onError, 则收到第二个onError事件会导致程序会崩溃.

作者：Season_zlc
链接：http://www.jianshu.com/p/464fa025229e
來源：简书
著作权归作者所有。商业转载请联系作者获得授权，非商业转载请注明出处。

那么Disposable用来干什么的呢，它的作用就是让Observer不在接收onNext onComplete和onError事件
比如在一连串业务操作中如果中途出现什么状况需要停掉正在进行的业务就可以使用这个,比如像下面这样用

    Observer<String> observer = new Observer<String>() {
        private Disposable mDisposable = null;
        @Override
        public void onSubscribe(Disposable d) {
            mDisposable = d;
        }

        @Override
        public void onNext(String value) {
            if ("111".equals(value)) {
                if (mDisposable != null && !mDisposable.isDisposed()) {
                    mDisposable.dispose();
                    mDisposable = null;
                }
            }
        }

        @Override
        public void onError(Throwable e) {

        }

        @Override
        public void onComplete() {

        }
    };

另外还有一个不同的地方是

public final Disposable subscribe() {}
public final Disposable subscribe(Consumer<? super T> onNext) {}
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError) {} 
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete) {}
public final Disposable subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) {}
public final void subscribe(Observer<? super T> observer) {}

observable.subscribe();被重载了很多个而且和1.0的也是有一些区别那具体怎么用呢

1、没有参数的调用后Observer不会任何事件，而observable的subscribe中的事件调用会依次执行

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            // 这里相当于1.0中的call函数  调用的顺序还是和1.0的时候一样的 只是使用的类和函数名有了少许改变
            //ObservableEmitter 时间发射器  其实可以理解为一个观察者对象
            log("Observable   CurrentThread : " + Thread.currentThread().getName());
            e.onNext("Hello");
            e.onComplete();// 1.0中函数名为onCompleted()
        }
    });
    
打印日志结果
08-08 11:18:39.713 24454-24454/com.example.rxjavademo I/MainActivity----Test: Observable   CurrentThread : main

2、subscribe(Consumer<? super T> onNext) 参数为一个Consumer对象的从下面的代码中可以看出，这里调用Observer只关心收到的onNext()不关系onComplete和onError 其实这里和上一篇讲的1.0中的Action1这个类的作用很相似就是对onNext的函数封装成了一个对于对象来使用，因为Consumer的内部函数accept(T t)就是一个有参无返回的函数而onNext(T t) 刚好也是同样的，所以这样你是不是发现onError(T t) 也是同样的是这样的。请继续看第三条

public interface Consumer<T> {
    /**
     * Consume the given value.
     * @param t the value
     * @throws Exception on error
     */
    void accept(T t) throws Exception;
}


Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            // 这里相当于1.0中的call函数  调用的顺序还是和1.0的时候一样的 只是使用的类和函数名有了少许改变
            //ObservableEmitter 时间发射器  其实可以理解为一个观察者对象
            log("Observable   CurrentThread : " + Thread.currentThread().getName());
            e.onNext("Hello");
            e.onComplete();// 1.0中函数名为onCompleted()
        }
    });

    Consumer<String> consumer = new Consumer<String>() {
        @Override
        public void accept(String s) throws Exception {
            log("Consumer   CurrentThread : " + Thread.currentThread().getName());
            log("onNext :" + s);
        }
    };

    observable.subscribe(consumer);
日志打印结果
08-08 11:23:37.163 28780-28780/com.example.baiguosong.rxjavademo I/MainActivity----Test: Observable   CurrentThread : main
08-08 11:23:37.163 28780-28780/com.example.baiguosong.rxjavademo I/MainActivity----Test: Consumer   CurrentThread : main
08-08 11:23:37.163 28780-28780/com.example.baiguosong.rxjavademo I/MainActivity----Test: onNext :Hello

3、subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError)。上面第二条中讲到Consumer就是对onNext(T t) 和onError(Throwabe t)的封装，看果不其然两个参数的时候就关系的是onNext和onError看日志就知道onNext和onError都执行了

Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            // 这里相当于1.0中的call函数  调用的顺序还是和1.0的时候一样的 只是使用的类和函数名有了少许改变
            //ObservableEmitter 时间发射器  其实可以理解为一个观察者对象
            log("Observable   CurrentThread : " + Thread.currentThread().getName());
            e.onNext("Hello");

// e.onComplete();// 1.0中函数名为onCompleted()

            e.onError(new NullPointerException());
        }
    });

    Consumer<String> onNextConsumer = new Consumer<String>() {
        @Override
        public void accept(String s) throws Exception {
            log("Consumer   CurrentThread : " + Thread.currentThread().getName());
            log("onNext :" + s);
        }
    };

    Consumer<Throwable> onErrorConsumer = new Consumer<Throwable>() {
        @Override
        public void accept(Throwable e) throws Exception {
            log("onError : " + e.toString());
        }
    };

    observable.subscribe(onNextConsumer,onErrorConsumer);
    
    日志打印结果
    08-08 11:35:49.043 7751-7751/com.example.baiguosong.rxjavademo I/MainActivity----Test: Observable   CurrentThread : main
    08-08 11:35:49.043 7751-7751/com.example.baiguosong.rxjavademo I/MainActivity----Test: Consumer   CurrentThread : main
    08-08 11:35:49.043 7751-7751/com.example.baiguosong.rxjavademo I/MainActivity----Test: onNext :Hello
    08-08 11:35:49.043 7751-7751/com.example.baiguosong.rxjavademo I/MainActivity----Test: onError : java.lang.NullPointerException

4、subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete)经过前面的讲解那么三个参数就一目了然了第三个参数Action肯定就是对应的onComplete()的函数的封装了无参无返回值，老规矩还是直接上代码

public interface Action {
    /**
     * Runs the action and optionally throws a checked exception.
     * @throws Exception if the implementation wishes to throw a checked exception
     */
    void run() throws Exception;
}

 Observable<String> observable = Observable.create(new ObservableOnSubscribe<String>() {
        @Override
        public void subscribe(ObservableEmitter<String> e) throws Exception {
            // 这里相当于1.0中的call函数  调用的顺序还是和1.0的时候一样的 只是使用的类和函数名有了少许改变
            //ObservableEmitter 时间发射器  其实可以理解为一个观察者对象
            log("Observable   CurrentThread : " + Thread.currentThread().getName());
            e.onNext("Hello");

// e.onComplete();// 1.0中函数名为onCompleted()

// e.onError(new NullPointerException());
e.onComplete();
}
});

    Consumer<String> onNextConsumer = new Consumer<String>() {
        @Override
        public void accept(String s) throws Exception {
            log("Consumer   CurrentThread : " + Thread.currentThread().getName());
            log("onNext :" + s);
        }
    };

    Consumer<Throwable> onErrorConsumer = new Consumer<Throwable>() {
        @Override
        public void accept(Throwable e) throws Exception {
            log("onError : " + e.toString());
        }
    };

    Action onCompleteAction = new Action() {
        @Override
        public void run() throws Exception {
            log("onComplete : run");
        }
    };

    observable.subscribe(onNextConsumer,onErrorConsumer,onCompleteAction);
    
    日志打印结果
    08-08 11:43:57.733 14894-14894/com.example.baiguosong.rxjavademo I/MainActivity----Test: Observable   CurrentThread : main
    08-08 11:43:57.733 14894-14894/com.example.baiguosong.rxjavademo I/MainActivity----Test: Consumer   CurrentThread : main
    08-08 11:43:57.733 14894-14894/com.example.baiguosong.rxjavademo I/MainActivity----Test: onNext :Hello
    08-08 11:43:57.733 14894-14894/com.example.baiguosong.rxjavademo I/MainActivity----Test: onComplete : run

5、subscribe(Consumer<? super T> onNext, Consumer<? super Throwable> onError, Action onComplete, Consumer<? super Disposable> onSubscribe) 这里又多了一个参数Consumer<? super Disposable> 通过前面的举例说明这里的第四个参数就没什么难度了吧 Disposable这个不就是前面讲到的那个让Observer不再接收事件的函数嘛

6、subscribe(Observer<? super T> observer) 这个也很好理解了直接看代码

Observer<String> observer = new Observer<String>() {
        private Disposable mDisposable = null;
        @Override
        public void onSubscribe(Disposable d) {
            mDisposable = d;
        }

        @Override
        public void onNext(String value) {
            log("onNext :" + value);

        }

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

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

    observable.subscribe(observer);
    
    日志打印结果
    08-08 11:50:43.103 20994-20994/com.example.baiguosong.rxjavademo I/MainActivity----Test: Observable   CurrentThread : main
    08-08 11:50:43.103 20994-20994/com.example.baiguosong.rxjavademo I/MainActivity----Test: onNext :Hello
    08-08 11:50:43.103 20994-20994/com.example.baiguosong.rxjavademo I/MainActivity----Test: onComplete :

以上内容就是2.0.1版本和1.0版本的对比讲解后面的内容都会基于2.0.1版本来学习研究，欢迎拍砖指教。

注：部分内容是看了这位大佬的 传送门
http://www.jianshu.com/p/464fa025229e

最后编辑于：2017.12.09 23:13:55

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 203,547评论 6赞 477
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,399评论 2赞 381
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 150,428评论 0赞 337
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,599评论 1赞 274
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,612评论 5赞 365
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,577评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,941评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,603评论 0赞 258
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,852评论 1赞 297
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,605评论 2赞 321
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,693评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,375评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,955评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,936评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,172评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 43,970评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,414评论 2赞 342

RxJava学习之旅二 2.0.1版本和1.0简单实用的对比讲解

推荐阅读更多精彩内容