如何在 Dart 中使用 StreamZip 合并流

Question

我有两个流：

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

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

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>>>。