firebase-返回多个查询作为collectionData？

Question

/a>运算符时，当平等数为10或更少时。当它大于10时，我将把数组分为多个长度10的子阵列，并初始化多个查询请求。

当长度小于10时，我只是将 Q 用作查询请求，返回返回collectionData（q，{idfield：'id''}）; 。但是，当我拥有 Q0 ， Q1 等时，我不知道如何以相同的方式返回它们，就像返回 Q 。

问题是如何返回 Q0 ， Q1 ，...使用与仅返回 q 的相同语法？

constructor(private firestore: Firestore) {
}

getUserChats() {
    const userId = '12345678910';
    const userRef = doc(this.firestore, `users/${userId}`);
    return docData(userRef).pipe(
        switchMap((data) => {
            let userChats = data.chats;
            let chatsRef = collection(this.firestore, 'chats');
            if (userChats.length <= 10) {
                //use the query normally as the 'in' operator has a limit of 10
                let q = query(chatsRef, where(documentId(), 'in', userChats));
                return collectionData(q, { idField: 'id' });
            } else {
                //breakdown the userChats array into sub-arrays of length 10
                //it is hardcoded for proof-of-concept
                let q0 = query(chatsRef, where(documentId(), 'in', userChats.slice(0, 10)));
                let q1 = query(chatsRef, where(documentId(), 'in', userChats.slice(10, 20)));
                //...
                //how to combine q0 and q1?
                return collectionData(????????????????, { idField: 'id' });
            }
        })
    );
}

Answer 1

这是我提出的解决方案：

• 将数据分为大小 10 （最后一个段可能具有 10 或更少），
• 为每个查询，使用在每个片段的操作员中，其中最多包含 10 平等性，
• 每个查询都将存储在一个查询中
• collection> collectiondata 然后用于每个查询中的每个查询返回可观察的
• 所有可观察物的数组将存储在一个可观察的阵列中。
• 函数 combineLatest 从rxjs中使用，然后与可观察到的数组一起使用，然后返回

  getUserChats() {
    const userId = 'aabbccdd';
    const userRef = doc(this.firestore, `users/${userId}`);
    return docData(userRef).pipe(
      switchMap((data) => {
        if (data && data.chats) {
          const userChats = data.chats;
          const chatsRef = collection(this.firestore, 'chats');
          let queries = [];
          if (userChats.length !== 0) {
            for (let i = 0; i < userChats.length; i += 10) {
              let q: Query<DocumentData> = query(
                chatsRef,
                where(documentId(), 'in', userChats.slice(i, i + 10))
              );
              queries.push(q);
            }

            let observablesData: Observable<DocumentData[]>[] = [];
            for (let i = 0; i < queries.length; i++) {
              let x = collectionData(queries[i], { idField: 'id' });
              observablesData.push(x);
            }
            return combineLatest(observablesData);
          }
        }
        return [null];
      })
    );
  }

以测试功能，确保检查检查功能 null 案例，因为这将引发一个例外：

this.chatService
      .getUserChats()
      .pipe()
      .subscribe((result: FirebaseChatroom[]) => {
        if (result !== null) {
          result = result.flat();
          //do something with result...
        }
      });