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方法就是返回了一个ObservableJustObservableJustObservable.subscribe创建了一个LambdaObserver观察者LambdaObserver主要有onSubscribe,onNext,onError,onComplete方法对应的执行的逻辑是对应的是类构造参数的回调接口调用了ObservableJust.subscribeActual入参是LambdaObserver创建了一个ScalarDisposableScalarDisposable先会调用LambdaObserver的onSubscribe然后调用ScalarDisposable.run根据上图其实就是调用LambdaObserver.onNext