默认情况下,RxJs主题为“热”,但是是否可以创建“冷”主题以从一开始就获取从其传播的所有值?
即:
let s = new Subject();
s.next(1);
s.next(2);
s.subscribe(n => console.log(n)); //to get here 1 2 3
s.next(3);
您可以使用ReplaySubject来做到这一点。要记住的一件事是,ReplaySubject期望在创建过程中有一个数字知道它应该缓冲多少个值。您不能缓冲所有元素。
const subject = new Rx.ReplaySubject(10);
subject.next("1");
subject.next("2");
subject.next("3");
subject.next("4");
subject.next("5");
subject.subscribe(
(val) => console.log(val)
);
subject.next("6");
// Logs out
// 1
// 2
// 3
// 4
// 5
// 6
jsbin:http://jsbin.com/rocofa/edit?js,控制台
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句