Rxjs-multicasting-operator-publishreplay

RxJS-マルチキャストオペレーターpublishReplay

publishReplayは動作サブジェクトを利用します。動作サブジェクトでは、値をバッファリングし、それを新しいサブスクライバーに再生して、ConnectableObservableを返すことができます。 作成されたオブザーバブルをサブスクライブするには、connect（）メソッドを使用する必要があります。

構文

publishReplay(value);//here value is the number of times it has to replay.

例

import { interval} from 'rxjs';
import { take, publishReplay} from 'rxjs/operators';

let observer = interval(1000).pipe(
   take(3),
   publishReplay(2)
);
const subscribe_one = observer.subscribe(
   x => console.log("Value from Sub1 = "+x)
);
const subscribe_two = observer.subscribe(
   x => console.log("Value from Sub2 = "+x)
);
observer.connect();
setTimeout(() => {
   const subscribe_three = observer.subscribe(
      x => console.log("Value from Sub3 = "+x)
   );
}, 2000);

出力

publishReplay Operator