Flutter Firebase：将Future<List<Service>>转为Stream<List<Service>>

首先纠正原函数的问题：你的原函数会直接返回空列表，因为循环里的get()是异步操作，.then()里的代码还没执行，函数就已经完成return了。要实现实时更新的列表流，得用Firestore的snapshots()监听文档变化，而非单次获取的get()。

以下是两种实现方案：

方式一：使用rxdart（推荐，更贴合实时列表需求） #

rxdart的Stream.combineLatest可以合并多个流，任意一个文档更新时，都会生成包含所有最新服务的列表：

import 'package:rxdart/rxdart.dart';
import 'package:cloud_firestore/cloud_firestore.dart';

Stream<List<Service>> getServicesStreamById(List<String> ids) {
  // 为每个ID创建单个服务的实时流
  final serviceStreams = ids.map((id) {
    return FirebaseFirestore.instance
        .collection('Services')
        .doc(id)
        .snapshots()
        .map((doc) {
      if (!doc.exists) {
        throw Exception('服务ID $id 不存在');
      }
      return Service.fromJson(doc.data()!);
    });
  }).toList();

  // 合并所有流，生成实时更新的服务列表
  return Stream.combineLatest(serviceStreams, (values) {
    return values.cast<Service>();
  });
}

代码说明： #

• 每个文档ID对应一个Stream<Service>，通过snapshots()监听文档的实时改动，每次快照更新时转换为Service对象。
• Stream.combineLatest会监听所有子流，只要有一个子流推送新值，就会收集所有子流的最新值组成列表并推送。
• 加入了文档不存在的错误处理，你也可以根据需求改为返回默认值或过滤掉无效条目。

方式二：使用Dart原生StreamZip（无第三方依赖） #

如果不想引入rxdart，可以用Dart自带的StreamZip，但它的行为是等待所有流都至少推送一次值后，只有当所有流都更新时才会推送新列表，适合不需要实时单个更新的场景：

import 'dart:async';
import 'package:cloud_firestore/cloud_firestore.dart';

Stream<List<Service>> getServicesStreamById(List<String> ids) {
  final serviceStreams = ids.map((id) {
    return FirebaseFirestore.instance
        .collection('Services')
        .doc(id)
        .snapshots()
        .map((doc) {
      if (!doc.exists) {
        throw Exception('服务ID $id 不存在');
      }
      return Service.fromJson(doc.data()!);
    });
  }).toList();

  return StreamZip(serviceStreams);
}

额外注意： #

• 可以给流添加错误处理，比如用handleError捕获网络或文档不存在的错误：

  return Stream.combineLatest(serviceStreams, (values) {
    return values.cast<Service>();
  }).handleError((error) {
    print('获取服务流出错：$error');
    // 这里可以返回默认列表或重新抛出错误
    return [];
  });
  

• 如果ID列表会动态变化，需要用BehaviorSubject之类的工具管理ID的变化，再动态创建和合并流。

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