Rxjava2基本订阅流程

Rxjava完成依次基本订阅主要由下图几个部分完成

Observable调用create(ObservableOnSubscribe<T>)方法创建Observable<T>,并实现抽象方法subscribeActual(observer),在subscribeActual中创建一个事件发射器ObservableEmitter<T>,首先通过observer去onSubscribe该发射器，然后ObservableOnSubscribe<T>去subscribe该发射器，调用ObservableEmitter.onNext(T)方法,并在其内部最终调用到observer.onNext(T)方法。而subscriberActual(observer)是Observable.subscribe(observer)的最终调用链。