如何在RxJS中将Observable转换为ReplaySubject？

以下是我现在要将Observable转换为ReplaySubject的内容:

const subject = new Rx.ReplaySubject(1);

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

这是进行转换的最佳方式,还是有更惯用的方式？

observable.subscribe(subject)如果您想要传递所有3种类型的通知,则可以使用,因为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,因此您将其从"冷"变为"热"(可能在您的用例中无关紧要).