如何准确地合并多个流在Firebase firest

Question

在你说这是一个重复的问题或者我应该使用嵌套流生成器之前，请听我说完。

我正在设计一个社交媒体类型的应用程序。我希望用户在关注其“我的追随者帖子”集合中的帖子时能够收到更新。在该应用程序中，该应用程序将检查firebase rtdb中当前用户的以下列表（他正在跟踪的人），并列出他们的UID。

我计划使用所述列表创建一个流列表（当然是按时间排序的），并将它们合并到一个流中，然后将其输入到私有提要页面上的流生成器中。

在此页面上，用户将能够轻松关注他们感兴趣的人发布的内容。

我认为这样一个系统比每个在“私人订阅源”集合中拥有文档的用户都更具成本效益，每当有人发布内容时，应用程序都会读取他们的关注者列表，然后迅速在他们的每个私人订阅源中发布更新。因为想象一个拥有200万粉丝的人。这意味着200万次即时写作。后来，200万人阅读。我认为，海报只需将帖子放在他们的“publicFeed”中，而不同的关注者只需收听该feed并与他们保持联系，这样会更具成本效益。

但是这需要实现多个流（多于2个）的合并。我该怎么做？

我尝试过阅读RxDart，但对我来说完全是希腊语。我相对来说是飞镖的初学者。我只编码了大约5个月。

Answer 1

我最近遇到了一个类似的情况，我建议您这样做（我正在使用cloud firestore，但我相信您已经编写了流，所以重要的部分是使用多个流）：

您必须将此插件添加到pub spec.yaml中：https://pub.dev/packages/rxdart

以下是存储库（在您的帖子中，比如newPosts、oldPosts）：

class PostRepository {

  static CollectionReference get collection => yourCollectionRef;
    
  static Stream<List<Post>> newPosts() {
    Query query = collection
        .where('Your condition like was viewed', isEqualTo: false)
        .orderBy('updateDate', descending: true)
        .limit(50);
    return query.snapshots().map<List<Post>>((querySnapshot) {
      final _newPosts = querySnapshot.documents.map((doc) {
        final post = Post.fromDoc(doc);
        return post;
      }).where((p) => p != null);

      return _newPosts
    });
  }

  static Stream<List<Post>> oldPosts() {
    Query query = collection
        .where('Your condition like was viewed', isEqualTo: true)
        .orderBy('updateDate', descending: true)
        .limit(50);
    return query.snapshots().map<List<Post>>((querySnapshot) {
      final _oldPosts = querySnapshot.documents.map((doc) {
        final post = Post.fromDoc(doc);
        return post;
      }).where((p) => p != null);

      return _oldPosts
    });
  }
}

然后，要获得多个流（以上两个流的组合），请在您的widget类中执行以下操作：

重要！您必须导入此-导入“包：rxdart/streams.dart”；

List<Post> newPosts;
List<Post> oldPosts;

Widget _pageContent() {
  return SingleChildScrollView(
    child: Column(
      children: [
        ListView.builder(
          shrinkWrap: true,
          physics: NeverScrollableScrollPhysics(),
          itemCount: newPosts.length,
          itemBuilder: (context, index) {
            return ListTile(
              title: Text(newPosts[index].title)
            );
          }
        ),
        ListView.builder(
          shrinkWrap: true,
          physics: NeverScrollableScrollPhysics(),
          itemCount: oldPosts.length,
          itemBuilder: (context, index) {
            return ListTile(
              title: Text(oldPosts[index].title)
            );
          }
        )
      ]
    )
  );
}

Widget _posts() {
  return StreamBuilder(
    stream: CombineLatestStream.list([
      PostRepository.getNewPosts(),
      PostRepository.getOldPosts()
    ]),
    builder: (context, snap) {
     if (snap.hasError) {

        debugPrint('${snap.error}');
        return ErrorContent(snap.error);

      } else if (!snap.hasData) {

        return Center(
          child: CircularProgressIndicator(),
        );

      }

      newPosts = snap.data[0];
      oldPosts = snap.data[1];

      return _pageContent();
    }
  );
}

我像是从头开始写代码的，所以可能会有一些小错误，但我希望你明白这一点，享受吧：）

Answer 2

您可以使用异步包中的StreamGroup：https://pub.dev/documentation/async/latest/async/StreamGroup-class.html将多个流中的事件分组-dart团队对其进行了充分的记录和维护。如果您没有RxDart经验，这是一个不错的选择。它没有rx的所有功能，但对于初学者来说，应该更容易理解这一点