RxJava线程切换的原理

1.当观察者订阅主题(被观察者)时：函数 会立刻执行ObservableCreate()方法中的subscribeActual()方法 在subscribeActual()方法中建立CreateEmitter()的实例，CreateEmitter()接口实现了Emitter(onNext,onError,onComplete)和Disposeable接口 observer 调用onSubscrib

>>阅读原文<<