Flutter：StreamBuilder流未更新

Question

在从 Firebase 获取数据并将其存储到本地 SQLite 数据库时，我的 StreamBuilder 在流更改后没有刷新，并且流也没有更新；

这是我的代码，用于从 Firebase 监听数据更改，然后将这些新聊天写入本地：

    /// LISTEN TO THE STREAM FROM FIREBASE AND THEN WRITE THE NEW MESSAGES TO THE LOCAL DATASE

  // Fetch normal messages
      firestore.fetchMessagesStream(chatRoomId).listen((event) async {
        for (QueryDocumentSnapshot message in event.docs) {
           _database.insert(
            'Messages',
            message.data()!,
            conflictAlgorithm: sql.ConflictAlgorithm.replace,
          );
        }
      });
      // Fetch calls
      firestore.fetchCallsStream(chatRoomId).listen((event) async {
        for (QueryDocumentSnapshot call in event.docs) {
          _database.insert(
            'Calls',
            call.data()!,
            conflictAlgorithm: sql.ConflictAlgorithm.replace,
          );
      // Fetch posts
      firestore.fetchPostsStream(chatRoomId).listen((event) async {
        for (QueryDocumentSnapshot post in event.docs) {
          _database.insert(
            'Posts',
            post.data()!,
            conflictAlgorithm: sql.ConflictAlgorithm.replace,
          );
        }
      });

这里是从本地 SQLite 数据库获取数据的代码：

/// STREAM FOR LISTENING THE CHANGES IN THE LOCAL DATABASE

Rx.combineLatest3(
      _database.query(
       'Messages',
        where: 'chatRoomId = ?',
        whereArgs: [chatRoomId],
        ).asStream(), // Returns the stream of the Messages Table in local databases
      _database.query(
        'Posts',
        where: 'chatRoomId = ?',
        whereArgs: [chatRoomId],
     ).asStream(), // Returns the stream of the Posts Table in local databases
      _database.query(
        'Calls',
        where: 'chatRoomId = ?',
        whereArgs: [chatRoomId],
       ).asStream(), // Returns the stream of the Calls Table in local databases
      (List<Map<String, dynamic>> streamingMessages,
          List<Map<String, dynamic>> streamingPosts,
          List<Map<String, dynamic>> streamingCalls) {
        /// VERY IMPORTANT: THE FOLLOWING PRINT STATEMENT WILL BE PRINT OUT EVERYTIME A NEW CHAT ARRIVE
        /// VERY IMPORTANT: THE FOLLOWING PRINT STATEMENT WILL BE PRINT OUT EVERYTIME A NEW CHAT ARRIVE
        /// VERY IMPORTANT: THE FOLLOWING PRINT STATEMENT WILL BE PRINT OUT EVERYTIME A NEW CHAT ARRIVE
        /// VERY IMPORTANT: THE FOLLOWING PRINT STATEMENT WILL BE PRINT OUT EVERYTIME A NEW CHAT ARRIVE
        /// VERY IMPORTANT: THE FOLLOWING PRINT STATEMENT WILL BE PRINT OUT EVERYTIME A NEW CHAT ARRIVE
        print('MySqlite: chat stream changes!');

        final List<dynamic> contents = [...streamingMessages, ...streamingPosts, ...streamingCalls];

        return contents;
      },
    );
  }

发送新消息时的预期时间线为：

用户发送了一条消息 --> 触发 Firebase 中的更改 --> 触发 LOCAL SQLite 添加新数据 --> 因为我们的 SQLite 添加了新的聊天，所以我们的 ChatScreen 应该刷新并且还有一条新的调试消息: 'MySqlite：聊天流改变！'由于 ChatScreen 正在侦听 SQLite 数据库流，因此应该在控制台中再次打印出来。

但实际结果是：

用户发送了一条消息 --> 成功触发 Firebase 中的更改 --> 但我没有看到正在刷新的屏幕，也没有在控制台中看到新的调试消息...

我已经为这个问题苦苦挣扎了好几天，我不知道为什么结果不是我想要的，如果我让 ChatScreen 直接收听 Firebase，它可以工作！ *

更新：

我刚发现如果我重建ChatScreen（弹出屏幕，然后再次打开），或者发送新消息时设置状态，我可以看到新消息，证明消息确实去了发送后进入 SQLite 数据库，但它只是没有触发 StreamBuilder。因此，Fetching Stream 可能有问题。

回答：

我刚刚发现 SQLite.query 函数不能作为 Stream 获取，我认为我可以使用“asStream”方法，但这没有做任何事情，这是 SQLite 包没有的缺失功能还没有实现，所以我添加了sqlbrite package，它作为原始 SQLite 包的包装器，它具有一些附加功能，例如将数据查询为流。 ^_^

Answer 1

我刚刚发现 SQLite.query 函数不能作为 Stream 获取，我认为我可以使用“asStream”方法，但这没有做任何事情，这是 SQLite 包没有的缺失功能还没有实现，所以我添加了sqlbrite package，它作为原始 SQLite 包的包装器，它具有一些附加功能，例如将数据查询为流。 ^_^