RxJava源碼解讀

Observable<String> observable = Observable.just("hello world");
Consumer<String> consumer2 = new Consumer<String>(){
    @Override
    public void accept(String s) throws Exception {
       System.out.println("Test1" + s);
    }
};
observable.subscribe(consumer2);

咱們從最簡單的一段代碼入手()

Observable.just

實際上just方法就是返回了一個ObservableJust

ObservableJust

Observable.subscribe

建立了一個LambdaObserver觀察者

LambdaObserver

主要有onSubscribe,onNext,onError,onComplete方法對應的執行的邏輯是對應的是類構造參數的回調接口

調用了ObservableJust.subscribeActual入參是LambdaObserver

建立了一個ScalarDisposable

ScalarDisposable

先會調用LambdaObserver的onSubscribe而後調用ScalarDisposable.run根據上圖其實就是調用LambdaObserver.onNext