如何等待concatMap处理的全部异步请求执行完成？

1. concatMap确实能实现顺序Ajax请求 #

没错，concatMap完全匹配你的需求——它会等待前一个内部Observable（也就是this.simpleFunc(elem)返回的每个Ajax请求）完成后，才会订阅并执行下一个请求，完美实现依次顺序执行的逻辑。

2. 如何等待所有请求全部完成 #

你不需要额外的waitForAll方法，当前的Observable流本身就会在所有请求完成后触发complete通知，直接利用这个特性即可：

方式一：通过subscribe的complete回调 #

from(elementsList).pipe(
  concatMap((elem) => this.simpleFunc(elem))
).subscribe({
  next: (response) => {
    // 单个请求完成后的处理逻辑（可选）
  },
  complete: () => {
    // 所有请求全部完成后执行这里的代码
    console.log('所有Ajax请求已全部执行完毕');
  },
  error: (err) => {
    // 任何一个请求失败都会触发这里，可按需处理错误
  }
});

方式二：用lastValueFrom转为Promise等待（适合异步函数场景） #

如果你习惯使用async/await，可以借助lastValueFrom把Observable转为Promise：

import { lastValueFrom } from 'rxjs';

async processAllRequests() {
  try {
    await lastValueFrom(
      from(elementsList).pipe(
        concatMap((elem) => this.simpleFunc(elem))
      )
    );
    console.log('所有Ajax请求已全部完成');
  } catch (error) {
    console.error('请求过程中出现错误:', error);
  }
}

// 调用函数
this.processAllRequests();

3. 关于forkJoin的疑问 #

forkJoin是用来并行执行所有Observable的，它会同时发起所有Ajax请求，等全部完成后返回结果，这和你需要的顺序执行逻辑完全冲突。所以如果必须保持请求的顺序性，不要将它和concatMap结合使用。只有当你不需要顺序、想最大化请求效率时，forkJoin才是合适的选择。

内容的提问来源于stack exchange，提问作者Semen Shekhovtsov