如何用RxJS操作符让reloadUser方法等待两个请求同时完成后发射Observable

你需要用RxJS的forkJoin操作符来实现两个请求的并行执行，并等待两者都完成后再发射结果。具体修改步骤如下：

1. 确保reloadUserGating()方法返回一个Observable（如果原本没有返回，需要先修改该方法，让它返回内部请求的Observable流）
2. 用forkJoin包裹两个并行请求，它会等待所有传入的Observable完成后，发射包含各请求结果的数组
3. 在pipe中处理结果，更新currentUserSubject并返回合并后的Observable

修改后的代码示例：

import { forkJoin } from 'rxjs';
import { tap } from 'rxjs/operators';

public reloadUser() {
  // 定义两个并行的请求流
  const gatingRequest$ = this.reloadUserGating();
  const userRequest$ = this.request.get(`${this.url}/`);

  return forkJoin([gatingRequest$, userRequest$]).pipe(
    tap(([gatingResult, user]) => {
      // 更新用户主题
      this.currentUserSubject.next(user);
      // 若需处理reloadUserGating的返回结果，可在此编写逻辑
    })
  );
}

补充说明 #

• forkJoin是处理多并行请求并等待全部完成的最优选择，只有当所有传入的Observable都发出完成信号时，它才会发射最终结果数组
• 如果reloadUserGating()原本没有返回Observable，必须调整该方法，让它返回内部执行的请求流，否则无法纳入并行控制逻辑
• 若需要在请求过程中实时获取各请求的中间值，可以考虑使用combineLatest，但它会在任一Observable发射新值时就触发回调，不符合“等待全部完成再发射”的需求

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