RxSwift核心流程图

父类提供方法

subscribe

AnyObserver

父类

event作为参数

继承自

AnonymousObservableSink（此时该类持有了持有了真ob）

create并传递闭包

_eventHandler

AnyObserver（AnonymousObservableSink）

run创建并把真ob传入

run方法调用闭包

Observable

asObservable().subscribe()

forwardOn（event）

Producer

ObserverBase

on方法

核心实现封装成闭包（_eventHandler）并保存为自身属性，然后把自己赋值给临时变量Observer（AnonymousObserver）并向后传递我们称这个临时变量为“真ob”

_subscribeHandler

onCore

observer.on是个无返回值闭包参数为event

AnonymousObservable

sink

父类提供的subscribe方法

保存了创建的闭包

EventHandler

保存的闭包被调用后，把闭包内的onNexterrorcompleted3个方法作为event传入

Disposables.create真ob作为参数

根据不同的event调用不同的实现闭包

observer.on

把event作为参数，调用真ob（父类）的 on方法