Rxjava2.0 发生订阅关系 的源码解析

由于要做一场关于rxjava2.0 的内部分享，本人便怀着期待的心情去了解了下rxjava2.0，关于rxjava2.0网上盛传的文章很多，本人觉得此作者下的rxjava系列的文章很到位，我的分享也是基于此人笔记展开的一场讨论。
此刻应该有地址：https://www.jianshu.com/u/c50b715ccaeb
花两个小时读完这10遍文章，你绝对对rxjava有了初步的了解。
本遍短文会在此系列文章基础之上分析 观察者如何与被观察者产生订阅关系的，以下请画重点：

Observable.create<Int> {
        it.onNext(1)
        it.onNext(2)
        it.onNext(3)
        it.onComplete()
        it.onNext(4)
        it.onNext(5)
    }.subscribe(object : Observer<Int> {
        override fun onComplete() {
            Log.d(TAG, "onComplete")
        }

        override fun onSubscribe(d: Disposable) {
            d.dispose()
        }

        override fun onNext(t: Int) {
            Log.d(TAG, "onNext$t")
        }

        override fun onError(e: Throwable) {
            Log.d(TAG, "onError${e.message.toString()}")
        }
    })

以上代码为正常的一段被观察者与观察者产生订阅关系的代码，源码的解析便从产生订阅关系的subscribe 方法开始分析，请容许我用粗鄙的工具图来解析我的分析思路，电脑前的你们只需要ctrl b 往下走就可以了，具体分析流程如下：

分析脑图.png

subscribe 对应到抽象类Observable中的subscribe ，而抽象类Observable中的subscribe又调用自己内部的subscribeActual 抽象方法，此处着重打引号“subscribeActual”，这是一个抽象的方法，具体的实现是由此次被观察者Observable实现的，而此次Observable对应的就是代码首段的Observable.create method，该方法就是创建具体的被观察者，由此方法追入 ObservableCreate 类，果然抽象方法“subscribeActual” 此处得到具体实现，该方法内部出现的CreateEmitter 就是具体持有观察者observer的对象，你主动调用的onNext 以及 onError、onComplete 都是由它分发给observer。具体源码展示如下所示：

subscribeActual 具体实现

onNext()

此处有几个地方画重点：
1.ObservableCreate subscribeActual 方法中， observer.onSubscribe(parent); 这句话就能解释为何每次observer中的onSubscribe都会首先被调用，parent 对应的就是CreateEmitter，CreateEmitter这个类实现了多个接口，其中与onSubscribe 方法绑定的就是Disposable接口

2.onNext 方法中有一个判断，!isDisposed()，此方法就是对应Disposable这个类，表示此次订阅关系是否已经被终止，如果已经被终止的话，被观察者不会响应观察者的方法。

下遍文章为大家带来rxjava2.0 scheduler的工作原理，容在下整理整理思路，在于诸位一一道来。
在下告辞！