如何将Observable<string>传入Firebase Firestore获取文档引用？

首先明确：Firebase Firestore没有直接接收Observable作为参数的方法，doc()方法必须传入实际的字符串ID，所以你需要先从Observable中提取出字符串值再调用该方法。

下面提供两种可行的解决方案：

方案一：返回Observable（推荐） #

因为Observable是异步数据流，最符合RxJS编程范式的做法是让函数也返回Observable，通过RxJS操作符提取值并生成文档引用：

import { Observable, switchMap, of } from 'rxjs';
import 'firebase/compat/firestore';

public matchesRef: firebase.firestore.CollectionReference;

getMatch(matchId$: Observable<string>): Observable<firebase.firestore.DocumentReference> {
  return matchId$.pipe(
    switchMap(matchId => of(this.matchesRef.doc(matchId)))
  );
}

• 使用switchMap操作符订阅传入的matchId$，获取流中发射的实际string值
• 用of将生成的文档引用包装成Observable返回，调用方可以通过订阅这个Observable拿到最终的文档引用

方案二：异步获取值转成Promise #

如果业务场景需要同步风格的返回（不推荐，因为Observable的异步特性），可以将Observable转为Promise，等待获取到值后再生成文档引用：

import { firstValueFrom } from 'rxjs';
import 'firebase/compat/firestore';

public matchesRef: firebase.firestore.CollectionReference;

async getMatch(matchId$: Observable<string>): Promise<firebase.firestore.DocumentReference> {
  // 等待Observable发射第一个值
  const matchId = await firstValueFrom(matchId$);
  return this.matchesRef.doc(matchId);
}

• 注意：RxJS 7及以上版本建议用firstValueFrom/lastValueFrom替代已废弃的toPromise()
• 这种方式需要确保Observable一定会发射值，否则会一直处于等待状态

原代码报错原因 #

你当前的错误是因为matchId是Observable<string>类型，而doc()方法要求传入原始的string类型——Observable是一个异步数据流的容器，并非直接的字符串值，因此无法直接传入。

内容的提问来源于stack exchange，提问作者Barry the Beginner