RxJava源码解读

共计 589 个字符，预计需要花费 2 分钟才能阅读完成。

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