observer in Rxjs

Question

私はObservableとObserverのパターンから始めました。私はさまざまなサイトを見て、Observableがプロデューサであり、Observerが消費者であることを発見しました。そして、私がコードの下を通過するとき、私はオブザーバーの意味を混乱させました。

export class AppComponent { 
private data:Observable; 
private dataObserver:Observer; 

constructor(private http: Http) { 
this.data = new Observable(observer => this.dataObserver = observer); 
} 

新しいObservableオブジェクトを作成する場合は、だれでも、オブザーバーの意味を提供するのに助けてください。

this.data =新しい観測（観察=> this.dataObserver =オブザーバー）

Answer 1

観測コンストラクタのパラメータは、その観察に加入観察と呼び出されるコールバックメソッドです。 Observableが作成されている場合、オブザーバは使用できません。

あなたはここでより多くの情報を見つけることができます。 http://reactivex.io/rxjs/class/es6/Observable.js~Observable.html#instance-constructor-constructor

観察可能が加入当初 ときに呼び出される関数を。この関数には、新しい の値を次に渡すことができるサブスクライバ、または エラーを発生させるためにエラーメソッドを呼び出したり、正常終了を通知するためにcompleteを呼び出すことができます。

、ここ http://reactivex.io/documentation/operators/create.html

あなたは作成 演算子を使って、ゼロから観測を作成することができます。この演算子には、オブザーバ をパラメータとして受け入れる関数を渡します。オブザーバのonNext、onError、および onCompletedメソッドを適切に呼び出すことで、この関数をObservableとして、 として動作するように記述します。

Aよく形成された有限観察可能で 観察者のonCompleted方法は、一度だけのいずれか呼び出そうとか、そのonErrorメソッド 正確に一度、その後 観察者の他のいずれかの方法を呼び出そうとしてはならない必要があります。