Dart与Firestore：如何绕开whereIn的10条限制获取多文档流？

你当前实现存在两个核心问题，直接导致了运行异常：

• 直接触发空对象报错的原因：声明的List event没有初始化实际实例，直接调用event.add时，操作的对象本身是null，自然抛出The method 'add' was called on null错误
• 逻辑层面的根本偏差：你试图将多个独立的文档流对象存入普通List后，把这个List强转为Stream返回，这和你需要的返回类型完全不匹配——普通List是静态数据结构，无法承担流的持续推送语义，强转操作本身就不会得到正确的流实例。

要实现不受Firestore whereIn 10条查询上限的多文档流监听，核心思路是将每个connection映射为独立的单条件查询流，再通过Dart的流聚合能力将这些独立流合并为统一的总流，任意一个被监听的文档发生变更时，总流自动汇总所有最新的文档数据推送给下游。

具体实现要点：

• 为每个connection生成独立的单uid查询流，因为单条件查询没有长度限制，完全绕开whereIn的条目上限
• 用流合并工具替代手动维护的普通列表，自动同步所有独立流的最新值
• 修正空列表的边界处理，返回空集合而非null流，降低下游空值处理的崩溃风险
• 修复原代码中的变量遮蔽问题，避免文档id取值错误

参考可运行代码实现（依赖Flutter生态常用的rxdart流工具库）：

Stream<List<SpecialEvents>> upcomingSpecialEventsStream(List connections) {
  // 空输入时返回空列表的流，避免下游接收到null触发异常
  if (connections.isEmpty) {
    return Stream.value(<SpecialEvents>[]);
  }

  // 将每个connection映射为独立的单文档查询流，存入初始化好的流列表
  final List<Stream<List<SpecialEvents>>> connectionStreams = connections.map((connection) {
    return _service.collectionStream(
      path: FirestorePath.specialEvents(),
      queryBuilder: (query) => query.where(
        'uid',
        isEqualTo: connection,
      ),
      // 原代码将文档id参数命名为connection，与外层循环的uid变量重名存在遮蔽问题，调整为docId避免取值错误
      builder: (data, docId) => SpecialEvents.fromMap(data, docId),
    );
  }).toList();

  // 聚合所有独立流，任意流数据更新时汇总全量事件列表返回
  return Rx.combineLatestList(connectionStreams)
      .map((nestedEvents) => nestedEvents.expand((eventGroup) => eventGroup).toList());
}

方案说明：

• 完全适配长连接列表场景：哪怕connections条目超过10个、甚至达到上百个，也不会触发Firestore的查询限制，不需要手动做批次拆分
• 流的语义完全匹配需求：当任意被监听的specialEvents文档发生新增、修改、删除时，总流会自动推送最新的全量事件集合，不需要手动维护监听状态
• 从根源解决空对象报错：所有用到的List都做了显式初始化，不存在调用未初始化对象方法的问题

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