如何按顺序角发送独立http请求

Question

我想发送10个独立的请求，一个接着一个按顺序发送。并希望在数组中获得所有结果。我尝试过forkjoin，但它并行地命中了所有请求。

对于并行请求

search(queryUrls) {
    queryUrls.forEach((query) => {
        observableBatch.push(this.http.post(query.url, query.data))
            .pipe(
                map((res) => res),
                catchError(e => of('Error'))
            );
    });

    //
    return forkJoin(observableBatch);
}

我可以订阅这个方法，并且可以在一个数组中得到所有的结果。但如何才能按顺序发送所有请求呢？

Answer 1

您需要改用concat。

concat将订阅first input Observable并发出其所有值，而不以任何方式改变或影响它们。当那个可观察到的东西完成时，它将订阅然后传递下一个可观察到的东西，并且再次发出它的值。这将被重复，直到操作员用完可观察的东西。当最后一个input Observable完成时，concat也将完成。

然后，如果希望将所有这些结果收集到数组中，则需要使用toArray运算符折叠结果。

const batched = queryUrls.map(query => this.http.post(query.url, query.data))
concat(batched).pipe(toArray()).subscribe(allResults => /**/)