如何在RxJS流中返回第一个Observable的结果？

你的思路其实完全站得住脚——在第二个异步操作完成后，把流的结果映射回第一个请求的组织对象，这是处理「先执行A，再用A的结果执行B，最终返回A」这类场景的标准做法。不过我们可以优化代码的简洁性，同时贴合RxJS的最佳实践，下面给你几个改进方案：

方案1：用RxJS内置工具替代手动封装Promise #

手动创建new Promise再手动管理subscribe和resolve/reject的方式太冗余了，RxJS 7+提供了firstValueFrom/lastValueFrom工具，可以直接把Observable转为Promise，代码会清爽很多：

import { firstValueFrom } from 'rxjs';
import { switchMap, map } from 'rxjs/operators';

// ...

return firstValueFrom(
  this.organizationController.send(CREATE_ORGANIZATION, organizationEvent).pipe(
    switchMap((org) => {
      if (org === null) {
        // 直接抛出异常，会被RxJS错误流捕获，最终自动转为Promise的reject状态
        throw new UnprocessableEntityException();
      }

      const organizationUserEvent: OrganizationUserEventDto = {
        dto: {
          userId: user.id,
          organizationId: org.id,
          role: Role.SUPER,
        },
      };

      // 执行第二个请求后，把流的结果映射回最初的org对象
      return this.organizationController.send(
        CREATE_ORGANIZATION_USER,
        organizationUserEvent
      ).pipe(map(() => org));
    })
  )
);

这个方案的优势 #

1. 减少冗余代码：用firstValueFrom自动处理Observable到Promise的转换，省去了手动写订阅、resolve/reject的样板代码。
2. 更安全的订阅管理：避免手动管理订阅带来的潜在内存泄漏风险（哪怕是单次请求，养成好习惯也很重要）。
3. 统一的错误处理：直接抛出异常会被RxJS的错误流自动捕获，最终转为Promise的reject状态，逻辑更连贯。

关于你尝试的withLatestFrom问题 #

你之前用withLatestFrom导致两次请求，是因为$org是冷Observable——每次订阅它都会重新执行一遍请求逻辑。当你在pipe里调用withLatestFrom($org)时，整个流的订阅会触发两次$org的订阅，所以才会重复调用创建组织的接口。这种场景下withLatestFrom并不适用，强行把它转成热Observable（比如用shareReplay）反而会增加不必要的复杂度。

你的初始思路其实没毛病 #

你之前用mergeMap+内部map返回org的做法完全正确，核心逻辑就是「等第二个操作完成后，把结果切回第一个请求的对象」——这是处理这类依赖型异步操作且需要返回上游结果的标准方式，并没有什么「更优雅」的魔法操作符，因为逻辑本身就是这样的。我们只是用RxJS的工具函数让代码更简洁而已。

备注：内容来源于stack exchange，提问作者Aaron Balthaser