上一篇文章 RXSwift基础用法及响应核心底层逻辑原理 中针对执行
Observable<Any>.create的具体SubscribeHandler调用并没有讲清楚，也就是开始执行observer.onNext("测试")这里， 针对这里再做个补充。
先来回顾下我们的代码：
fileprivate func bindView(){
let ob = Observable<String>.create { (observer) -> Disposable in
observer.onNext("测试")
observer.onCompleted()
return Disposables.create()
}
_ = ob.subscribe(onNext: { (text) in
print("订阅到:\(text)")
}, onError: { (error) in
print("error:\(error)")
}, onCompleted: {
print("完成")
}, onDisposed: {
print("销毁")
})
}
之前的执行顺序不多赘述，没搞明白的希望可以按照前一篇博客一步步加断点走一遍。
当执行到 observer.onNext("测试") 时, 我们首先要明白 observer 是什么对象，看图:
AnonymousObservableSink, "管道"对象
我们看到 AnonymousObservableSink 管道对象调用了 parent._subscribeHandler(AnyObserver(self)) 也就说，observer.onNext("测试") 中，observer 是一个 AnyObserver 对象，而且这个 AnyObserver 在初始化时传递的是 self，也就是说 是一个
AnonymousObservableSink 类型，那么我们点进去，( cmd + AnyObserver),
AnyObserver对象
由于我们使用的是 AnyObserver(self) ，self 是 AnonymousObservableSink 类型，遵循协议ObserverType，所以我们来到图中标红线的构造方法中。
self.observer = observer.on，observer 是一个 AnonymousObservableSink类型，那么点击.on方法
查找AnonymousObservableSink的on方法
on方法中调用 self.forwardOn(event)
AnonymousObservableSink的on方法
继续点进去：
forwardOn方法
这里的
self.observer 其实就是一路被传来传去的 AnonymousObserver，
简单来说: 从调用self.asObservable().subscribe(observer),依次传给了AnonymousObservable和AnonymousObservableSink.
好，再由 AnonymousObserver执行on，这里前一篇文章有讲过，不多解释，直接说流程：
AnonymousObserver 执行on，找到其父类 ObserverBase，父类 func on(_ event: Event<E>)调用回子类( AnonymousObserver )的onCore(_ event: Event<Element>)方法，最终实现 我们手写代码ob.subscribe onNext / onError / onCompleted/ 的event的调用。
注 :
最后提醒大家注意的是有一个坑 没绕过去就可能会很难懂：
注意看加注释的地方，不要把对应的匿名函数搞混了
提醒1
提醒2
总结：
序列创建
Observable<String>.create
创建AnonymousObservable内建类，保存创建序列回调函数到其属性_subscribeHandler中。订阅
_ = ob.subscribe(onNext 、 onError 、 onCompleted
创建AnonymousObserver内部订阅者对象，保存了用户输入的接收到订阅事件回调(即我们代码中的 print("订阅到:\(text)" 等)到其成员变量_eventHandler中，执行了AnonymousObservable中保存的_subscribeHandler创建序列回调函数。执行发送消息/响应事件
observer.onNext("测试")
其实是调用了AnyObserver之前在第二步时，所保存的接收到事件时的回调。
网友评论