如何避免嵌套Observables 用RxJS实现前序Observable完成后执行mergeMap

算力阿峰

2026-9-26

RxJS 提供了原生操作符组合可以实现你要的效果，不需要自定义 waitUntilCompletes，用 toArray + concatMap 组合即可。

逻辑说明

toArray 会等待上游 Observable 完全触发完成通知后，把上游所有 next 抛出的返回值打包为一个数组，一次性向下游抛出，刚好对应你要的「等前序请求全量完成」的逻辑，产出的数组就是你需要的 resDataArray。
concatMap 本身的调度逻辑就是严格按顺序执行：收到上游抛出的值后才创建内部 Observable，且必须等前一个内部 Observable 完全执行完成，才会处理下一个上游值。这里因为 toArray 只会抛出一次值，因此 concatMap 只会触发一次子页面爬取逻辑，完全符合你的流程要求。

改造后代码

import { toArray, concatMap } from 'rxjs';

const pagination = [["url-1", "url-2", "url-3", "url-4"], ["url-5"]];
const timeInterval = 2;

sendRequestsInIntervals(pagination, timeInterval )
  .pipe(
    toArray(),
    concatMap((resDataArray) => {
      return sendRequestsInIntervals(resDataArray, timeInterval );
    })
  )
  .subscribe({
    next(x) {
      console.log(x);
    },
    error(err) {
      console.error(err);
    },
    complete() {
      console.log("done");
    },
  });