我想要实现的是同时执行许多Ajax请求(数量从10到1000+不等),但在5个活动请求的限制下(类似于请求执行的FIFO队列)。
例如,我们有一个包含100个HTTP地址的数组,我们想要获取前5个并为每个地址执行GET请求。如果这5个请求中的任何一个结束,则另一个地址应进入队列并执行其GET请求,直到所有100个地址都发出请求并完成。
使用reactor库,有一个适合我的描述的limitRequest运算符。
我的问题是如何使用rxjs实现类似的行为?
我尝试使用buffer操作符,但它会在完成5个请求后发出结果,而我想要的是在请求完成时立即发出结果。
我已经创建了一个stackblitz,试图对此进行实验。
例如,我们有一个包含100个HTTP地址的数组,我们想要获取前5个并为每个地址执行GET请求。如果这5个请求中的任何一个结束,则另一个地址应进入队列并执行其GET请求,直到所有100个地址都发出请求并完成。
使用reactor库,有一个适合我的描述的limitRequest运算符。
我的问题是如何使用rxjs实现类似的行为?
我尝试使用buffer操作符,但它会在完成5个请求后发出结果,而我想要的是在请求完成时立即发出结果。
我已经创建了一个stackblitz,试图对此进行实验。