Rxjs：如何流創建

Question

在瞭解觀察的，觀察的方式，訂閱我剛來到這個例子，無法理解這個例子，我很迷惑

​​

發生了什麼嗎？我們在這裏創造的觀察者流？但觀察者是用訂閱方法訂閱流時從流接收數據的人，並且有3個方法onNext，complete和error。

也給我舉例。我們在哪裏創建一個流，一個觀察者（獨立）以及這個獨立觀察者如何訂閱一個可觀察對象。

Answer 1

該文件是您瞭解可觀測物體及其力學的入門。現在事實是，它可能會非常密集一些。我建議你看看這裏：

• Creating and Subscribing to Simple Observable Sequences
• learning-observable-by-building-observable由本·萊什（上RxJS開發領導）
• The introduction to Reactive Programming you've been missing
• Hot and Cold observables : are there 'hot' and 'cold' operators?

簡短的回答你的問題是即：

• Rx.Observable.create返回一個實現接口（在文檔中描述）的對象（observable），其中包含一個subscribe函數。當您執行.subscribe(observer)中的subscribe函數時，您作爲Rx.Observable.create的參數傳遞的工廠函數將使用該參數執行observer參數。在你的情況下，Simon等值將被推送給觀察者（實現觀察者接口，包括onNext,onCompleted等）。
• 通常使用超載形式.subscribe(function yournamehere(){...})。因此，觀察者是從該函數內部製作的，其onNext是您傳遞的函數，它的onError和onCompleted是默認值。
• 對於你的問題的第二部分，參考。文檔https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/observer.md