RxJS:Multicasting运算符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();

输出

RxJS:Multicasting运算符publishLast

作者:terry,如若转载,请注明出处:https://www.web176.com/rxjs/1941.html

(0)
打赏 支付宝 支付宝 微信 微信
terryterry
上一篇 2021年2月9日 下午12:48
下一篇 2021年2月9日 下午12:51

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用 * 标注