rxjs - 如何将最后发出的项目 "replay"发送给每个订阅者？

Question

在 RxJS 中，我想为每个新订阅者提供最后一个发出的项目。但是我如何在 Observable 链中做到这一点？

this.http.get().map().replaySubject().refCount()

Answer 1

这个答案是指RxJS 5:

一种方法是使用 publishReplay :

this.http
  .get()
  .map()
  .publishReplay(1)
  .refCount();

---

如果您的源是一个源，则完成(这对于 rest-call 来说是典型的，因为它在收到响应后完成)，您也可以使用 publishLast :

this.http
  .get()
  .map()
  .publishLast()
  .refCount();

---

第三种方式(给你最大的灵 active )是使用外部的 BehaviorSubject 或 ReplaySubject:

public myData$: BehaviorSubject<any> = new BehaviorSubject(null); // initial value is "null"

public requestData(): BehaviorSubject<any> {
    this.http
       .get()
       .map()
       .do(data => this.myData$.next(data))
       .subscribe();

    return this.myData$.skip(1); // the returned subject skips 1, because this would be the current value - of course the skip is optional and depends on the implementation of the requesting component
}

在您的组件中，您可以通过 myData$.subscribe(...) 获取当前“缓存”数据或通过 requestData().subscribe (...) 获取最新数据。