用于ajax请求的Rxjs/reactor限制运算符等效项

Question

我试图实现的是同时执行许多ajax请求(从10到1000+不等(，但活动请求的数量限制为5(就像执行请求的FIFO队列一样(。

例如，我们有一个100个http地址的数组，我们想获得前5个地址，并为每个地址执行get请求，如果这五个请求中的任何一个结束，那么另一个地址应该进入队列并执行其get请求，直到所有100个地址都发出请求并完成。

对于反应堆库，有一个limitRequest操作符，它符合我的描述

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

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

我创建了一个堆叠式

尝试在这种上进行实验

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