Rxjs-multicasting-operator-publishlast

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

publishBehaviourはAsyncSubjectを利用し、ConnectableObservableを返します。 作成されたオブザーバブルをサブスクライブするには、connect（）メソッドを使用する必要があります。

例

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

let observer = interval(1000).pipe(
   take(10),
   publishLast()
);
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();

出力

publishLastオペレーター