Rxjs/reactor中针对ajax请求的限制运算符等效方法是什么？

Question

我想要实现的是同时执行许多Ajax请求（数量从10到1000+不等），但在5个活动请求的限制下（类似于请求执行的FIFO队列）。

例如，我们有一个包含100个HTTP地址的数组，我们想要获取前5个并为每个地址执行GET请求。如果这5个请求中的任何一个结束，则另一个地址应进入队列并执行其GET请求，直到所有100个地址都发出请求并完成。

使用reactor库，有一个适合我的描述的limitRequest运算符。

我的问题是如何使用rxjs实现类似的行为？

我尝试使用buffer操作符，但它会在完成5个请求后发出结果，而我想要的是在请求完成时立即发出结果。

我已经创建了一个stackblitz，试图对此进行实验。

- Panos K

Answer 1

你只需要使用两个mergeMap操作符就可以完成所有这些操作。 mergeMap操作符接受第二个参数，即并发Observable的数量。第一个mergeMap将用于解包来自服务器的URL数组，第二个将保持5个并发请求：

根据你提供的stackblitz演示（顺便说一句，感谢提供演示），你可以将所有内容放入单个RxJS链中。

from(axios.get("https://jsonplaceholder.typicode.com/photos")).pipe(
  mergeMap(response => response.data // Unwrap the array of URLs into single emissions
    .filter(x => x.albumId === 100)
    .map(x => x.url)
  ),
  mergeMap(url => of(url).pipe(delay(1000 * Math.random())), 5), // Mock additional requests with of() and delay()
).subscribe(console.log);

您的更新示例：https://stackblitz.com/edit/photo-dls-pb27pn?file=index.js

（注：此为原文内容，已无需翻译）

- martin

---

哇，谢谢，这太棒了。我最后也用了 mergeMap，不过这个解决方案更加内聚。 - Panos K