我试图使用RxDart将Firestore中的两个流合并到一个流中,但它只返回一个流的结果
Stream getData() {
Stream stream1 = Firestore.instance.collection('test').where('type', isEqualTo: 'type1').snapshots();
Stream stream2 = Firestore.instance.collection('test').where('type', isEqualTo: 'type2').snapshots();
return Observable.merge(([stream2, stream1]));
}
Run Code Online (Sandbox Code Playgroud)