rxjs5 - 如何在 RxJS 中创建冷主题？

Question

默认 RxJs 主题 是“热”，但是是否可以创建“冷”主题以获取从一开始传播的所有值？

IE。:

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);

Answer 1

您可以使用 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,console