javascript - 使用 RxJS 一次限制请求数

Question

假设我有 10 个 url，我想为每个 url 发出一个 HTTP 请求。

我可以创建一个 URL 的可观察对象，然后是 .flatMap() 对每个 URL 的请求，然后是 .subscribe 以获取结果。但这会同时发出所有请求。

有没有办法将请求的数量限制为固定数量，以免服务器重载

Answer 1

RxJS v6 更新

将您的并行限制作为第二个参数通过 mergeMap 进行管道传输

const MAX_PARALLEL_QUERIES = 3;
let allResults = [];
let observables = [] // fill with observables
from(observables)
            .pipe(mergeMap(observable => observable, MAX_PARALLEL_QUERIES))
            .subscribe(
                partialResults => {
                    allResults = allResults.concat(partialResults);
                },
                err => {
                    // handle error
                },
                () => {
                    // get here when all obserable has returned
                    allResults.forEach(result=> {
                        // do what you want
                    });
                }
            );