在flutter firetore中合并流

dependencies:
  rxdart: ^0.27.0

Stream<List<DocumentSnapshot>> stream1 = Firestore.instance.collection('collection1').snapshots();
Stream<List<DocumentSnapshot>> stream2 = Firestore.instance.collection('collection2').snapshots();

import 'package:rxdart/rxdart.dart';

Stream<List<DocumentSnapshot>> mergedStream = Observable.combineLatest2(stream1, stream2, (List<DocumentSnapshot> data1, List<DocumentSnapshot> data2) {
  // 在这里处理合并后的数据
  // 返回合并后的数据列表
});

StreamBuilder<List<DocumentSnapshot>>(
  stream: mergedStream,
  builder: (BuildContext context, AsyncSnapshot<List<DocumentSnapshot>> snapshot) {
    if (snapshot.hasData) {
      // 处理数据并更新UI
    } else if (snapshot.hasError) {
      // 处理错误
    }
    return Container();
  },
);