如何将 Observable 转换为 ReplaySubject？

Question

这是我现在正在做的，将 Observable 转换为 ReplaySubject:

const subject = new Rx.ReplaySubject(1);

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

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

Answer 1

如果你想传递所有 3 种类型的通知，你可以只使用 observable.subscribe(subject)，因为 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，因此您将其从 "cold" 更改为 "hot"（也许这在您的 use-case 中并不重要）。

Answer 2

和第一个答案一样，因为对象也是观察者。

const subject = new Rx.ReplaySubject(1);
observable.subscribe(subject);

Answer 3

这取决于你所说的'convert'是什么意思。

如果您需要让您的可观察对象共享并重放这些值，请使用 observable.pipe(shareReplay(1))。

如果你也想拥有订阅者功能，你需要使用订阅原始 Observable 的 ReplaySubject observable.subscribe(subject);。

如何将 Observable 转换为 ReplaySubject？

How to convert an Observable to a ReplaySubject?

rxjs

rxjs5