合并两个Stream时出错：Stream类型未定义concat方法

你遇到的问题是因为Dart原生Stream类没有concat、merge这类方法，这些方法是第三方库rxdart提供的扩展功能。以下是具体解决步骤：

1. 添加rxdart依赖 #

在项目的pubspec.yaml文件中添加依赖：

dependencies:
  flutter:
    sdk: flutter
  rxdart: ^0.27.7 # 可替换为最新版本

执行flutter pub get完成依赖安装。

2. 导入rxdart包 #

在代码文件顶部导入：

import 'package:rxdart/rxdart.dart';

3. 根据需求选择合并方法 #

场景1：先播完snapshot1的所有事件，再播snapshot2（串行拼接） #

使用concatWith方法：

StreamProvider<QuerySnapshot> dataStream(String userUid) {
  return StreamProvider<QuerySnapshot>((ref) {
    final snapshot1 = FirebaseFirestore.instance
        .collection('catégorie')
        .where('uid', isEqualTo: userUid)
        .snapshots();
    final snapshot2 = FirebaseFirestore.instance
        .collection('catégorie')
        .where('uid', isEqualTo: 'default')
        .snapshots();
    return snapshot1.concatWith([snapshot2]);
  });
}

场景2：同时监听两个流，有事件立即发射（并行合并） #

使用mergeWith方法：

StreamProvider<QuerySnapshot> dataStream(String userUid) {
  return StreamProvider<QuerySnapshot>((ref) {
    final snapshot1 = FirebaseFirestore.instance
        .collection('catégorie')
        .where('uid', isEqualTo: userUid)
        .snapshots();
    final snapshot2 = FirebaseFirestore.instance
        .collection('catégorie')
        .where('uid', isEqualTo: 'default')
        .snapshots();
    return snapshot1.mergeWith([snapshot2]);
  });
}

无第三方库的替代方案 #

如果不想引入rxdart，可以用Dart原生的StreamGroup实现并行合并：

import 'dart:async';

StreamProvider<QuerySnapshot> dataStream(String userUid) {
  return StreamProvider<QuerySnapshot>((ref) {
    final snapshot1 = FirebaseFirestore.instance
        .collection('catégorie')
        .where('uid', isEqualTo: userUid)
        .snapshots();
    final snapshot2 = FirebaseFirestore.instance
        .collection('catégorie')
        .where('uid', isEqualTo: 'default')
        .snapshots();
    
    final group = StreamGroup<QuerySnapshot>();
    group.add(snapshot1);
    group.add(snapshot2);
    return group.stream;
  });
}

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