RxJS 阻止 switchMap 首先发送请求答案

【问题标题】：RxJS prevent switchMap to send request in first placeRxJS 阻止 switchMap 首先发送请求
【发布时间】：2019-06-22 08:10:47
【问题描述】：

我有一个组件订阅了一个同时触发多次的事件。此订阅向服务器发起请求以获取数据。我想要实现的是只触发一个请求。

相反，在最终请求完成之前，我会收到大量已取消的请求：

更新：

this.someObject.onEvent()
  .pipe(switchMap((filterCriterias) => this.loadData(filterCriterias)))
  .subscribe((res) => {
    this.data = res;
});

有没有办法创建一个集水池，只触发最后一个请求，如图所示（首先不会收到取消的请求）？

我正在使用 RxJs 6.3

提前致谢！

【问题讨论】：

【解决方案1】：

您似乎可以使用exhaustMap 而不是switchMap。

exhaustMap 将忽略所有后续发射，直到内部 Observable 完成。所以即使onEvent() 发出五次，也只有第一次会触发this.loadData()。在活动的this.loadData() 完成之前，所有其他发射都将被忽略。

this.someObject.onEvent()
  .pipe(
    exhaustMap(() => this.loadData())
  )
  .subscribe((res) => ...);

【讨论】：

【解决方案2】：

this.someObject.onEvent()
  .pipe(debounceTime(300),switchMap(() => this.loadData()))
  .subscribe((res) => {
    this.data = res;
});

【讨论】：