rxjs - 如何将Observable转换为ReplaySubject？

Question

这是我现在要做的将Observable转换为ReplaySubject的操作：

const subject = new Rx.ReplaySubject(1);

observable.subscribe(e => subject.next(e));

这是进行转换的最佳方法，还是还有一种惯用的方法？

Answer 1

如果要传递所有3种类型的通知，则只能使用observable.subscribe(subject)，因为主题已经表现得像观察者。例如：

let subject = new ReplaySubject();
subject.subscribe(
  val => console.log(val),
  undefined, 
  () => console.log('completed')
);

Observable
  .interval(500)
  .take(5)
  .subscribe(subject);

setTimeout(() => {
  subject.next('Hello');
}, 1000)

观看现场演示： https://jsbin.com/bayewo/2/edit?js,console

但是，这有一个重要的后果。由于您已经订阅了源Observable，因此将其从“冷”更改为“热”（在您的用例中可能无关紧要）。