flutter - 如何在Dart中使用StreamZip合并流

Question

我有两个流:

Stream<List<Order>>  stream1 = pendingStream();
Stream<List<Order>>  stream2 = preparingStream();

我正在尝试使用 StreamZip包中的 package:async/async.dart像这样合并流...

Stream<List<Order>> getData() {
     Stream<List<Order>>  stream1 = pendingStream();
     Stream<List<Order>>  stream2 = preparingStream();
    return StreamZip([stream1, stream2]);
}

但是它不会编译。说:

The element type 'Stream<List<Order>>' can't be assigned to the list type 'Stream<Order>'.

据我了解，StreamZip应该接受两个流？我在做什么错？

Answer 1

您正在创建一个StreamZip<T>，它将按其refer in the documentation的方式发出其合并流的每个事件的List<T>。
每个合并的流都发出List<Order>类型，因此这意味着您将创建一个合并的流，该流将发出List的List。
基本上，您只需要将返回类型从Stream<List<Order>>更改为Stream<List<List<Order>>>即可。