订阅流并在 flutter dart 中转发

问题描述

我使用 firestore 订阅这样的流：

db.collection(collection).snapshots().listen((QuerySnapshot snapshot) {
  // something
});

listen 返回一个 StreamSubscription<QuerySnapshot>

现在我想编写一个方法，即订阅此流，以便在获得新结果时可以做一些事情。但是同样的方法应该自己返回一个这个数据流。我试过这个：

static Stream<QuerySnapshot> listenOnCollection(String collection) async* {
    db.collection(collection).snapshots().listen((QuerySnapshot snapshot) {
      // do something and Now forward incoming snapshot
      yield snapshot;
    });
  }

这不会起作用，因为 yield 在内部上下文中甚至都不知道。我怎样才能做到这一点？非常感谢！

解决方法

已测试，正常运行

static Stream<QuerySnapshot> listenOnCollection(String collection) async* {
    var stream = db.collection(collection).snapshots();
    await for(final snapshot in stream){
        yield snapshot;
    }
}

,

您可以映射和转换流然后返回它：

static Stream<QuerySnapshot> listenOnCollection(String collection){
  return db.collection(collection).snapshots().map((QuerySnapshot snapshot) {
     // do something and now forward incoming snapshot
     return snapshot;
  });
}