看個例子:
調用Observable的subscribe方法,傳入一個包含回調函數的observer對象:
後兩個參數都是undefined:
在toSubscriber函數裡,因為nextOrObserver是我手動傳入的對象,是以前兩個IF條件均不滿足:
進入預設實作,建立一個Subscriber對象:
Subscriber是Subscription的子類:
我們現在的Subscriber的構造函數裡,建立一個SafeSubscruber執行個體:this作為parent subscriber傳入
EmptyObserver是從./Observer導入進來的:
從SafeSubscriber的實作能看出,傳入的Observer對象的next,error和complete這些函數名稱都是寫死的,必須符合這個命名規範:
Object.create()方法建立一個新對象,使用現有的對象來提供新建立的對象的__proto__。
執行subscribe:
sink的destination包含了應用程式傳入的complete, next, error邏輯:
這裡能看到,subscribe的邏輯就是,周遊所有Observable參數,依次調用observer的next方法,最後再調用一次complete方法:
next調用私有的_next方法:
this._next調用this.destination.next:
最終調用到應用程式員傳入的next方法:
最後的輸出: