在Dart中合并Firestore的独立查询流

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

Stream<QuerySnapshot> query1 = FirebaseFirestore.instance
    .collection('collection1')
    .where('field1', isEqualTo: 'value1')
    .snapshots();

Stream<QuerySnapshot> query2 = FirebaseFirestore.instance
    .collection('collection2')
    .where('field2', isEqualTo: 'value2')
    .snapshots();

Stream<List<QuerySnapshot>> mergedStream = Rx.combineLatest2(
  query1,
  query2,
  (QuerySnapshot snapshot1, QuerySnapshot snapshot2) {
    return [snapshot1, snapshot2];
  },
);

mergedStream.listen((List<QuerySnapshot> snapshots) {
  // 处理合并后的数据
  QuerySnapshot snapshot1 = snapshots[0];
  QuerySnapshot snapshot2 = snapshots[1];

  // 对查询结果进行操作
  // ...
});