javascript - RxJS 运算符在完成之前不会再次发送到内部可观察对象

Question

我正在寻找类似于 switchMap 的运算符，但我不想取消之前的内部可观察对象，而是希望它等待其内部可观察对象完成，然后再向其发送第二次。

一个常见的用例是用户快速点击一个按钮，通过管道传输到 HTTP 请求，然后转发以供显示，如下所示:

click$.pipe(switchMap(() => this.http.get("/something"))).subscribe(res =>//);

这将在用户每次单击按钮时取消 http 请求。相反，我想忽略按钮点击，直到内部可观察对象完成，然后才向它发出第二次，依此类推。

这个用例是否有运算符或运算符的简单组合？谢谢!

Answer 1

检查 exhaustMap .它似乎完全符合您的需求。

exhaustMap ignores every new projected Observable if the previous projected Observable has not yet completed. Once that one completes, it will accept and flatten the next projected Observable and repeat this process.