从 Firebase firestore 查询数据时如何在流内等待

Question

对于上下文，我使用 Getx 状态管理进行 flutter，并且需要在我的 Rx> 对象上调用 list.bindStream(availabilityStream()) 。 这是我的availabilityStream方法

  static Stream<List<Availability>> availabilityStream() {
    return FirebaseFirestore.instance
        .collection('availability')
        .where('language',
            isEqualTo: GetStorageController.instance.language.value)
        .snapshots()
        .map((QuerySnapshot query) {
      List<Availability> results = [];
      for (var availablity in query.docs) {
        availablity["cluster"].get().then((DocumentSnapshot document) {
          if (document.exists) {
            print("Just reached here!");
            //! Ignore doc if cluster link is broken
            final model = Availability.fromDocumentSnapshot(
                availabilityData: availablity, clusterData: document);
            results.add(model);
          }
        });
      }
      print("result returned");
      return results;
    });
  } 

，我的可用性集合上的集群字段是另一个集合的引用字段。这里的问题是我需要等待 .get() 调用我的 firestore 或函数在返回数据之前返回。我无法在 map 函数或 Stream 的返回类型内等待变化。那么我如何在这里等待我的函数调用呢？

Answer 1

根据我从评论中得到的建议，我使用 Stream.asyncMap 来等待所有网络调用 future 完成。

这是我更新的存储库

class AvailabilityRepository {
  static Future<Availability> getAvailabilityAndCluster(
      QueryDocumentSnapshot availability) async {
    return await availability["cluster"]
        .get()
        .then((DocumentSnapshot document) {
      if (document.exists) {
        //! Ignore doc if cluster link is broken
        final model = Availability.fromDocumentSnapshot(
            availabilityData: availability, clusterData: document);
        return model;
      }
    });
  }


  static Stream<List<Availability>> availabilityStream() {
    return FirebaseFirestore.instance
        .collection('availability')
        .where('language',
            isEqualTo: GetStorageController.instance.language.value)
        .snapshots()
        .asyncMap((snapshot) => Future.wait(
            snapshot.docs.map((e) => getAvailabilityAndCluster(e))));
  }
}

我认为它的工作原理是，正常的 .map 函数从 getAvailabilityAndCluster() 方法返回多个承诺，然后所有异步执行的进程都被放入 Future.wait() 中，这是一个等待的大承诺里面的所有承诺都要完成。然后将其传递给 .asyncMap() ，等待 Future.wait() 完成，然后再继续其结果。