如何用RxJS的forkJoin返回[User, Result]元组并行处理请求？

你只需要在生成请求的时候，把原始User对象和请求结果关联起来就行啦。用RxJS的map操作符在每个请求流内部，把结果和用户对象打包成数组：

const deletionRequests = users.map(user => 
  this.userService.deleteUser(user.id).pipe(
    map(result => [user, result] as [User, boolean])
  )
);

forkJoin(deletionRequests).subscribe(results => {
  // 现在results的类型就是Array<[User, boolean]>了
  results.forEach(([user, deletionResult]) => {
    if (deletionResult) {
      // 在这里根据结果更新用户列表，比如移除对应的用户
      this.users = this.users.filter(u => u.id !== user.id);
    }
  });
});

为什么这么做？ #

• 原来的写法里，forkJoin只会收集每个请求的返回值（也就是布尔值），但我们通过在每个请求流里用map把原始user和请求结果打包，forkJoin最终收集到的就是每个请求对应的「用户-结果」对。
• 加上as [User, boolean]是给TypeScript明确的类型提示，避免类型推断模糊的问题，用JavaScript的话可以直接去掉这部分。

额外小提示 #

如果担心单个删除请求失败导致整个forkJoin终止，可以加上catchError来处理错误：

const deletionRequests = users.map(user => 
  this.userService.deleteUser(user.id).pipe(
    map(result => [user, result] as [User, boolean]),
    catchError(err => {
      console.error(`删除用户${user.id}失败`, err);
      // 返回包含用户和失败标记的结果，保证整个流继续执行
      return of([user, false] as [User, boolean]);
    })
  )
);

这样就算某个请求出错，你依然能知道是哪个用户的删除操作出了问题，还能继续处理其他请求的结果。

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