如何解决 Observable<Observable<{...}>[ ]> 到 Observable<{...}[ ]>？

Question

我正在尝试将两个可观察对象组合成一个可观察对象，因此我可以使用来自这两个对象的信息。可观察对象都是来自 NoSQL 数据库（Cloud Firestore 数据库）中两个不同集合的文档。两个集合共享一个具有相同值（uid 和 partnerID）的字段。我首先创建了一个查询来获取第一个可观察对象，这个查询返回一个Observable<{Object1}[]>。如果我尝试添加代码以获取第二个可观察对象并将其与现有对象结合，我会得到一个Observable<Observable<{Object1 merged with Object2}>[]>。

如何确保生成的 observable 是一个由对象组成的数组，这些对象是我从数据库中提取的这两个对象的组合？

我的目标是在我的 Angular 项目中使用组合的 observable 对象。我正在尝试使用 rxjs 运算符来实现这一点。

这是我的服务中没有第二个可观察对象的函数：

queryMatches(fieldNameOfRole, boolValueOfAccepted) {
    return this.authService.user$.pipe(
      switchMap(user => {
        return this.angularFirestore
          .collection('matches', ref => ref.where(fieldNameOfRole, '==', user ? user.uid : '')
            .where('accepted', '==', boolValueOfAccepted))
          .snapshotChanges()
          .pipe(
            map(actions => {
              return actions.map(a => {
                const data = a.payload.doc.data() as Match;
                const matchId = a.payload.doc.id;
                return { matchId, ...data };
              });
            })
          );
      })
    );
  }

这会产生以下返回：

(method) MatchStoreService.queryMatches(fieldNameOfRole: any, boolValueOfAccepted: any): Observable<{
    initiatorID: string;
    partnerID: string;
    matchedOffer: string;
    accepted: boolean;
    id: string;
}[]>

这就是我尝试将它与第二个可观察对象结合起来的方式：

queryMatches(fieldNameOfRole, boolValueOfAccepted) {
    return this.authService.user$.pipe(
      switchMap(user => {
        return this.angularFirestore
          .collection('matches', ref => ref.where(fieldNameOfRole, '==', user ? user.uid : '')
            .where('accepted', '==', boolValueOfAccepted))
          .snapshotChanges()
          .pipe(
            map(actions => {
              return actions.map(a => {
                const data = a.payload.doc.data() as Match;
                const matchId = a.payload.doc.id;
                return { matchId, ...data };
              });
            })
          );
      }),
      map(matches => {
        return matches.map(match => {
          return this.userStoreService.getUserById(match.partnerID).pipe(
            map(user => {
              return { ...match, ...user };
            })
          );
        });
      })
    );
  }

这会产生以下返回：

(method) MatchStoreService.queryMatches(fieldNameOfRole: any, boolValueOfAccepted: any): Observable<Observable<{
    uid: string;
    firstname: string;
    lastname: string;
    dateOfBirth: Date;
    sex: string;
    city: string;
    activities: string[];
    offers: string[];
    mail?: string;
    ... 4 more ...;
    matchId: string;
}>[]>

更新

我是如何实现 getUserById() 的：

getUserById(uid) {
    return this.angularFirestore
    .collection<any>(`users`)
    .doc<User>(uid).valueChanges();
   }

Answer 1

只需像这样使用 forkJoin 运算符

 map(matches => {
        return combineLatest(matches.map(match => {
          return this.userStoreService.getUserById(match.partnerID).pipe(
            map(user => {
              return { ...match, ...user };
            })
          );
        }));
      })