由于要做一场关于rxjava2.0 的内部分享，本人便怀着期待的心情去了解了下rxjava2.0，关于rxjava2.0网上盛传的文章很多，本人觉得此作者下的rxjava系列的文章很到位，我的分享也是基于此人笔记展开的一场讨论。
此刻应该有地址：//www.greatytc.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 往下走就可以了，具体分析流程如下：
subscribe 对应到抽象类Observable中的subscribe ，而抽象类Observable中的subscribe又调用自己内部的subscribeActual 抽象方法，此处着重打引号“subscribeActual”，这是一个抽象的方法，具体的实现是由此次被观察者Observable实现的，而此次Observable对应的就是代码首段的Observable.create method，该方法就是创建具体的被观察者，由此方法追入 ObservableCreate 类，果然抽象方法“subscribeActual” 此处得到具体实现，该方法内部出现的CreateEmitter 就是具体持有观察者observer的对象，你主动调用的onNext 以及 onError、onComplete 都是由它分发给observer。具体源码展示如下所示：
此处有几个地方画重点：
1.ObservableCreate subscribeActual 方法中， observer.onSubscribe(parent); 这句话就能解释为何每次observer中的onSubscribe都会首先被调用，parent 对应的就是CreateEmitter，CreateEmitter这个类实现了多个接口，其中与onSubscribe 方法绑定的就是Disposable接口
2.onNext 方法中有一个判断，!isDisposed()，此方法就是对应Disposable这个类，表示此次订阅关系是否已经被终止，如果已经被终止的话，被观察者不会响应观察者的方法。
下遍文章为大家带来rxjava2.0 scheduler的工作原理，容在下整理整理思路，在于诸位一一道来。
在下告辞！
