Flutter - 接收并修改来自 Stream 的数据

Question

我正在尝试执行以下操作：

1. 侦听 Firestore 流，以便在添加新文档时，StreamBuilder 将接收它、修改它，然后呈现它。

“修改”获取 Stream 数据（其中包括 Firestore UID），使用该 UID 从 Firestore 获取数据，然后使用该数据填充 StreamBuilder。

因此流程是：添加新文档 -> Stream 获取文档 -> 函数从该文档获取 UID -> 函数使用该 UID 从 Firestore 获取更多数据 -> 函数返回以使用新数据填充 StreamBuilder。

我当前的设置如下——它有效，但 FutureBuilder 显然在每次重建小部件时都会调用 Firestore，而没有人希望这样。

  Stream<QuerySnapshot> upperStream;

  void initState() {
    super.initState();
    upperStream = aStream();
}

  Stream<QuerySnapshot> aStream() {
    return Firestore.instance
        .collection('FirstLevel')
        .document(/*ownUID (not related to stream)*/)
        .collection('SecondLevel')
        .snapshots();
  }

  Future<List> processStream(List streamData) async {
    List futureData = List();

    for (var doc in streamData) {
      Map<String, dynamic> dataToReturn = Map<String, dynamic>();
      DocumentSnapshot userDoc = await Firestore.instance
          .collection('FirstLevel')
          .document(/*OTHER USER'S UID FROM STREAM*/)
          .get();

      dataToReturn['i'] = userDoc['i'];

      futureData.add(dataToReturn);
    }
    return futureData;
  }
...
...
//The actual widget
        Expanded(
          child: StreamBuilder(
              stream: upperStream,
              builder: (context, snapshot) {
                // Error/null handling
                return FutureBuilder(
                    future: processStream(snapshot.data.documents),
                    builder: (context, futureSnap) {
                     // Error/null handling
                      return ListView.builder(
                          shrinkWrap: true,
                          itemCount: futureSnap.data.length,
                          scrollDirection: Axis.vertical,
                          itemBuilder: (context, index) {
                           //Continuing with populating
                          });
                    });
              }),
        ),

处理这样的流程的最佳方法是什么？创建一个方法，修改 Firestore 流中的数据然后返回，而根本不需要 ListView.builder？

编辑：我尝试像这样创建自己的流：

  Stream<Map<String, dynamic>> aStream2() async* {

    QuerySnapshot snap = await Firestore.instance
        .collection(FirstLevel)
        .document(/*OWN UID*/)
        .collection(SecondLevel)
        .getDocuments();

    for (var doc in snap.documents) {
      Map<String, dynamic> data = Map<String, dynamic>();
      DocumentSnapshot userDoc = await Firestore.instance
          .collection(FirstLevel)
          .document(/*OTHER USER'S UID RECEIVED FROM STREAM*/)
          .get();

      data['i'] = userDoc['i'];

      yield data;
    }
  }

但是，当新文档添加到 SecondLevel 集合时，流不会被触发/更新。

Answer 1

好吧，我想我找到了解决方案的路径。我从流中获取数据，对其进行修改，然后在一种方法中将其生成给 StreamBuilder，而不再需要 FutureBuilder。正如克里斯托弗·摩尔在评论中提到的，关键是await for。流方法如下所示：

  Stream<List> aStream() async* {

    List dataToReturn = List();

    Stream<QuerySnapshot> stream = Firestore.instance
        .collection(LevelOne)
        .document(OWN UID)
        .collection(LevelTwo)
        .snapshots();

    await for (QuerySnapshot q in stream){
      for (var doc in q.documents) {
        Map<String, dynamic> dataMap= Map<String, dynamic>();

        DocumentSnapshot userDoc = await Firestore.instance
            .collection('UserData')
            .document(doc['other user data var'])
            .get();

        dataMap['i'] = userDoc['i'];
        //...//
        dataToReturn.add(dataMap);
      }
      yield dataToReturn;
    }
  }

然后 StreamBuilder 会根据我的需要填充修改后的数据。