如何按顺序发送多个长耗时服务器请求？RxJS实现问题排查

你的代码里concatAll()用错了场景：getAll()返回的是Observable<Account[]>，它只会发出一个值（整个数组），concatAll()是用来处理「Observable的Observable」的，对数组无效。这导致concatMap拿到的参数是整个Account数组，而不是单个Account对象，调用update(acc.id,...)时acc.id是undefined，不仅请求可能异常，而且只会执行一次，自然没有后续请求。

把数组转换成逐个发出单个Account的Observable，再用concatMap保证顺序执行：

1. 先导入from操作符：

import { from } from 'rxjs';

2. 修改组件代码：

this.service.getAll().pipe(
  // 将数组转为逐个发出单个Account的Observable
  switchMap(accounts => from(accounts)),
  // 顺序执行每个update请求，前一个完成后再启动下一个
  concatMap(acc => this.service.update(acc.id, { synchronize: true }))
).subscribe({
  next: () => {
    // 可选：单个请求完成后的操作
  },
  complete: () => {
    // 所有请求全部完成后再设置flag，原代码每次请求完成都设置，按需调整
    this.someFlag = false;
  }
});

• concatMap本身就会缓存后续的元素，等待当前内部Observable（也就是update请求）完成后，再处理下一个元素，完全符合你「顺序执行、逐个等待完成」的需求。
• 如果getAll()可能被多次触发，switchMap会取消之前的请求，只处理最新的结果；如果需要保留所有请求结果，可换成mergeMap，但这里场景用switchMap更合理。

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