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