RxJS Observablesは1人の加入者だけが処理できますか？

Question

私はObservablesとRxJSの仕組みを理解しようとしているので、これを使う方法のすべてではないかもしれません。

私はAngular2アプリケーションを使用しています。さらに、RxJS Observablesを使用してイベントを送信しています。今特別なタイプのエラーイベントについては、イベントが別のサブスクライバによってすでに処理されているかどうかを知りたいと思います。 Observableに複数のサブスクライバが存在する可能性があり、イベントの全責任を負い、他の人がそれをもはや取得しない可能性があります。

このアイデアは、ルーティングイベントがWPFでどのように機能するかに基づいています。設定した場合、イベントが取り扱わマークされる場合は、trueに設定し、

;：イベントハンドラでは、プロパティHandledを持ってRoutedEventArgsパラメータを取得しますそうでなければfalse。この値を読み取る場合、trueは、クラスハンドラーまたはルートに沿ったインスタンスハンドラーのいずれかが、すでにこのイベントを処理済みとしてマークしていることを示します。そのようなハンドラが処理されたイベントをマークしていないことを示します。 https://docs.microsoft.com/en-us/aspnet/core/fundamentals/middleware - - ミドルウェアがASP.NETコアパイプラインの中でどのように機能するか

別の実装例は以下のようになりますが、次のミドルウェアを呼び出すか、単に結果を返すことができます。

私はobservableパイプに投げたいイベントにHandledプロパティを追加することを考えていましたが、それがRxJSでこれを行う慣習的な方法であるかどうかはわかりません。

Answer 1

通常、観測可能でこれを行う方法はではありません。は観察可能なものを誰にも渡し、誰もがそれを購読します。代わりに、それぞれの関係者に「パイプラインに追加する」チャンスを与え、最後に一度購読します。これを行うには多くの方法があります。最も簡単なのは、誰にも観測可能なものを与えないことです。しかし、その代わりに彼らはコールバックを提供してみましょう：

class Foo { 

    observable = ...; 
    callbacks = []; 

    addCallback(callback) { this.callbacks.push(callback); } 

    constructor() { 

     // subscribe to the observable and call any registered callbacks 
     this.observable.subscribe(e => { 
      for (const cb of this.callbacks) { 
       // callback returns true if it has "handled" the event 
       if (cb(e)) { 
        return; // do not call any other callbacks 
       } 
      } 
     }); 
    } 
} 

const foo = new Foo(); 

// subscriber1 handles "type1" events 
foo.addCallback(ev => ev.type === "type1"); 

// subscriber2 
foo.addCallback(ev => ev.type === "type2"); 

は、これが最も簡単な方法です。 Fooには、クライアントごとに観測値を公開し、その結果を監視してパイプラインを構築する方法があります。