Angular中如何在Observable管道中同时传递首个switchMap的authUser与后续操作结果

嘿，我完全懂这种“明明之前用过但突然记不起来”的感觉！其实解决这个问题的核心很简单：把你需要保留的authUser和每一步的操作结果一起包装起来，让它们在整个Observable管道里同步传递，不用找什么复杂的RxJS操作符，用基础的map就能搞定。

我帮你调整一下代码，你一看就明白：

this.auth.user.pipe(
  // 第一步：把authUser和firestore文档结果合并传递
  switchMap((authUser) => {
    if (!authUser) {
      return of(null); // 处理未登录的情况，返回空值或你需要的默认值
    }
    const docRef = doc(this.firestore, firebaseCollections.UsersCollection, authUser.uid);
    // 关键：用map把authUser和getDoc的结果包装成对象
    return from(getDoc(docRef)).pipe(
      map(firestoreDoc => ({ authUser, firestoreDoc }))
    );
  }),
  // 第二步：判断文档是否存在，并继续保留authUser
  map(({ authUser, firestoreDoc }) => {
    // 注意：DocumentSnapshot需要用exists()方法判断是否有数据，不是直接判断对象是否存在
    const exists = firestoreDoc.exists();
    return { authUser, exists };
  }),
  // 第三步：现在你可以同时拿到authUser和exists的值了！
  switchMap(({ authUser, exists }) => {
    // 这里写你的业务逻辑，比如根据exists状态做不同的请求或处理
    if (exists) {
      // 示例：用户已存在，返回用户数据或其他Observable
      return of({ user: authUser, isRegistered: true });
    } else {
      // 示例：用户不存在，返回注册引导或其他Observable
      return of({ user: authUser, isRegistered: false });
    }
  })
).subscribe(result => {
  // 处理最终结果
  console.log(result);
});

核心思路说明： #

• 不要让每一步操作只返回当前步骤的结果，而是把需要跨步骤保留的变量（比如authUser）和当前结果合并成一个对象/数组，这样整个管道里的每一步都能访问到之前的变量。
• 如果觉得对象解构麻烦，也可以用数组包装（比如[authUser, firestoreDoc]），后面用([authUser, firestoreDoc])解构，但对象的可读性更强，推荐使用。
• 顺便纠正你原来代码里的小细节：Firebase的getDoc返回的是DocumentSnapshot对象，不管文档是否存在都会返回这个对象，所以判断是否有数据必须用exists()方法，而不是直接判断对象是否为真。

备注：内容来源于stack exchange，提问作者Radu Hatos