我显然误解了StreamGroup.merge的工作原理或者stream的工作原理，或者两者都误解了！我有两个流在firestore中查询同一个字段。我使用merge创建了一个名为mergedStream的流。它在streamBuilder中使用，为应用程序提供服务。以下是我的代码：

Stream<List<Order>> stream1({Order order})  {
    return _service.collectionStream(
        path: APIPath.orders(),
        queryBuilder: (query) =>
            query.where('orderStatus', isEqualTo: 'Pending'),
        builder: (documentSnapshot) => Order.fromFirebase(documentSnapshot));
  }

  Stream<List<Order>> stream2({Order order})  {
     return _service.collectionStream(
        path: APIPath.orders(),
        queryBuilder: (query) =>
            query.where('orderStatus', isEqualTo: 'Preparing'),
        builder: (documentSnapshot) => Order.fromFirebase(documentSnapshot));
  }

和我用于流构建器的合并流：

Stream<List<Order>> mergedStream() {
    final s1 = preparingStream();
    final s2 = pendingStream();
    return StreamGroup.merge([s2, s1]);
  }

切换[s2, s1]的顺序会改变显示的流。当页面加载时，我会暂时看到另一个流，但它会消失，另一个流会出现。我如何合并这些流？
编辑：我添加flutter标记是因为它周围的阅读可能是problem和StreamBuilder
编辑：这有一点帮助：（评论中的链接，只是一个概念证明，流合并）但流searchResult()不更新时，有一个他流的状态变化...你必须刷新浏览器。

Stream<List<Order>> searchResult() {
    List<Stream<List<Order>>> streamList = [stream1(), stream2()];

    var x = Rx.merge(streamList).scan<List<Order>>((acc, curr,i) {
      return acc ?? <Order>[]
        ..addAll(curr);
    });
    //this test shows that the stream gets contents from both query streams
    // x.map((convert){ convert.documents.forEach((f){print(f.data["name"]);});}).listen(print);

    return x;
  }