上一篇文章 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.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之前在第二步时，所保存的接收到事件时的回调。