javascript - RxJSでObservableを完了するにはどうすればよいですか

Question

Observableがあるとしましょう:

var observable = Rx.Observable
    .fromEvent(document.getElementById('emitter'), 'click');

どうすればそれを完全にすることができますか (サブスクライブされたすべてのオブザーバーのonCompleteイベントをトリガーするものは何ですか) ?

Answer 1

この現在の形では、できません。オブザーバブルは、完了しないソースから派生しているため、それ自体は完了できません。できることは、このソースを完全な条件で拡張することです。これは次のように機能します。

var end$ = new Rx.Subject();
var observable = Rx.Observable
    .fromEvent(document.getElementById('emitter'), 'click')
    .takeUntil(end$);

終わりたい時observableはするend$.onNext("anything you want here");。それは、終了イベントがあなたによって生成された場合です。これがそのイベント (キー押下など) を生成する別のソースである場合、そのソースから派生したオブザーバブルを の引数として直接配置できますtakeUntil。

ドキュメンテーション：

• http://reactivex.io/documentation/operators/takeuntil.html
• https://github.com/Reactive-Extensions/RxJS/blob/master/doc/api/core/operators/takeuntil.md