Flutter中async*函数返回Stream异常求助：Firebase聊天应用函数重构

你的函数返回空数组的原因有几个：

1. 对Firestore的snapshots()返回的Stream只做了map转换，但没有订阅或转发这个Stream，导致map内部的代码根本不会执行。
2. 你在函数末尾直接yield了初始化的空messages列表，此时Stream还没开始处理数据，自然返回空。
3. 使用固定的messages列表会导致后续新消息累积，不符合实时Stream的更新逻辑。

重构后的代码 #

Stream<List<ChatMessage>> getForumChatStream(String forumId) async* {
  // 获取指定forum的文档数据，拿到messageIds数组
  final docSnap = await firestore.collection('forums').doc(forumId).get();
  final Forum forum = Forum.fromMap(docSnap.data()!);

  // 如果messageIds为空，直接返回空列表的Stream，避免无效查询
  if (forum.messageIds.isEmpty) {
    yield [];
    return;
  }

  // 转发openMessages的实时Stream，并将每个snapshot转换为ChatMessage列表
  yield* firestore
      .collection('openMessages')
      .where('messageId', whereIn: forum.messageIds)
      .orderBy('timeSent', descending: true)
      .snapshots()
      .map((snapshot) {
        // 每次snapshot更新时，重新生成ChatMessage列表，避免数据累积
        return snapshot.docs.map((doc) => ChatMessage.fromMap(doc.data())).toList();
      });
}

关键改进点 #

• 使用yield*直接转发处理后的Stream，这样每次Firestore数据更新时，都会自动向订阅者发送最新的消息列表。
• 每次snapshot更新时，通过map直接生成新的ChatMessage列表，避免了原代码中列表累积的问题。
• 增加了空数组判断，当messageIds为空时直接返回空列表，避免不必要的Firestore查询。

内容的提问来源于stack exchange，提问作者Ali99