RxJava源碼分析系列：
RxJava系列一：從使用層面分析源碼及執(zhí)行流程
RxJava系列二：根據(jù)操作符分析整個(gè)上下游的執(zhí)行流程
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> e) throws Exception {
e.onNext("1");
}
}).map(new Function<String, String>() {
@Override
public String apply(String s) throws Exception {
return s+"----";
}
}).subscribe(new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(String s) {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
1.首先分析下上面最簡(jiǎn)單例子的調(diào)用流程毫缆，首先是調(diào)用create方法創(chuàng)建一個(gè)Oberable對(duì)象朋魔，然后調(diào)用map方法最后再注冊(cè)一個(gè)Observer，
調(diào)用create方法產(chǎn)生一個(gè)ObservableCreate拱礁，查看下這個(gè)類恩闻，在創(chuàng)建的時(shí)候會(huì)將ObservableOnSubscribe傳入并記錄塌衰，這個(gè)類在以后會(huì)用到
2.調(diào)用map方法豌注，這個(gè)方法會(huì)創(chuàng)建一個(gè)ObservableMap對(duì)象，查看下這個(gè)類揉忘，在調(diào)用這個(gè)方法的時(shí)候我們傳進(jìn)去一個(gè)this跳座，ObservableCreate和ObservableMap都是繼承Observable，Observable中有各種操作符泣矛，所以這個(gè)this也就是ObservableCreate疲眷，經(jīng)過(guò)了這個(gè)map操作后，被觀察者對(duì)象變?yōu)榱薕bservableMap
3.調(diào)用ObservableMap的subscribe方法乳蓄，然后會(huì)找到父類Observable的subscribe方法咪橙，查看下這個(gè)方法，里面調(diào)用了subscribeActual(observer)方法虚倒，這個(gè)方法是abstract****的，也就是子類必然要實(shí)現(xiàn)這個(gè)方法产舞，也就是要查找的是ObservableMap的subscribeActual(observer)方法魂奥，這個(gè)observer也就是我們上面?zhèn)鬟f的對(duì)象。
- 查看下ObservableMap的subscribeActual(observer)方法易猫，下面有幾個(gè)對(duì)象需要注意耻煤，source是我們上面說(shuō)的ObservableCreate對(duì)象，這個(gè)t是我們傳遞的observer對(duì)象，function也就是上面我們定義的Function對(duì)象哈蝇，也就是我們對(duì)傳遞進(jìn)來(lái)的observer進(jìn)行了一個(gè)封裝棺妓，成為了MapObserver，這樣就會(huì)向上游走（Rxjava開發(fā)者常說(shuō)的上下游炮赦，這個(gè)上游我的理解就是當(dāng)注冊(cè)觀察者后會(huì)不斷的向上走找到最上游的Observable對(duì)象）怜跑，所以也就是調(diào)用了ObservableCreate的subscribeActual(observer)方法，此時(shí)這個(gè)observer已經(jīng)變?yōu)榱薓apObserver.里面包含我們定義的Observer吠勘。
5.然后走到ObservableCreate的subscribeActual(observer)方法查看（此時(shí)已經(jīng)是MapObserver）性芬，發(fā)現(xiàn)不出所料里面也有一個(gè)source.subscribe方法，這個(gè)source是ObservableOnSubscribe剧防，這個(gè)時(shí)候看明白了植锉，也就是在執(zhí)行create方法的時(shí)候我們傳進(jìn)去的參數(shù)對(duì)象，并且我們重寫了他的subscribe方法峭拘。并將一個(gè)發(fā)射器參數(shù)傳遞進(jìn)去了subscribe方法中俊庇，查看下這個(gè)發(fā)射器，在創(chuàng)建Emitter時(shí)鸡挠，我們將封裝好的MapObserver也傳遞進(jìn)去了暇赤。然后我們使用Emitter執(zhí)行OnNext方法，所以就會(huì)調(diào)用MapObserver的OnNext方法宵凌，
6.查看下MapObserver類鞋囊，上面第四步說(shuō)過(guò)了這個(gè)actual就是我們創(chuàng)建的Observer對(duì)象，也就是最終執(zhí)行的方法瞎惫。所以MapObserver的OnNext方法也就是執(zhí)行Function中的apply方法溜腐。然后向下在調(diào)用actual的OnNext方法，這個(gè)我們創(chuàng)建的Observer的OnNext方法也就最終調(diào)用了瓜喇，這樣整個(gè)流程就執(zhí)行結(jié)束挺益，執(zhí)行OnNext方法也就是我們整個(gè)下游的流程。
總結(jié)：
以上只是列個(gè)一個(gè)除卻創(chuàng)建操作符以外的一個(gè)map操作符乘寒，當(dāng)然你可以使用多個(gè)操作符望众，流程都是一樣的，無(wú)非就是將我們創(chuàng)建的Observer對(duì)象通過(guò)subscribe方法逐步的包裝直到達(dá)到最上游的subscribe方法伞辛，er這個(gè)方法中就會(huì)使用發(fā)射器進(jìn)行事件的發(fā)射烂翰，然后再將包裝的Observser對(duì)象調(diào)用OnNext方法之后不斷的拆包裝不斷的調(diào)用OnNext方法，直到到達(dá)最下游的OnNext方法（也就是我們注冊(cè)的Observer）所以上游和下游按照對(duì)象來(lái)說(shuō)蚤氏，上游就表示Obserable甘耿，下游表示Observer，當(dāng)我們一經(jīng)注冊(cè)O(shè)bservser后就會(huì)逐步調(diào)用上游的subscribe方法達(dá)到頂層后再逐步調(diào)用下游的OnNext方法竿滨，這樣就達(dá)到了鏈?zhǔn)秸{(diào)用佳恬，整個(gè)操作流也就完成了捏境。
簡(jiǎn)單的畫個(gè)圖：
