javascript - Bacon.js バスに相当する RxJS は何ですか?

Question

Bacon.js の Bus のように、イベントを直接プッシュできる Observable を作成するにはどうすればよいですか?

Answer 1

RxJS で同等のものはサブジェクトと呼ばれます。Observer と Observable の両方です。したがって、イベントをプッシュするには、その Observer インターフェース (onNext、onError、および onCompleted メソッド) を使用します。次に、Observable のように、サブスクライブ、マップ、zip、フィルター処理を行うことができます。公式ドキュメントの例を次に示します。

var subject = new Rx.Subject();

var subscription = subject.subscribe(
    function (x) { console.log('onNext: ' + x); },
    function (e) { console.log('onError: ' + e.message); },
    function () { console.log('onCompleted'); });

subject.onNext(1);
// => onNext: 1

subject.onNext(2);
// => onNext: 2

subject.onCompleted();
// => onCompleted

subscription.dispose();

Subject の入門ガイドはこちらで、Subject API のドキュメントはこちらで確認できます。