我有两条小溪,Stream<A>
和Stream<B>
.我有一个C
类型的构造函数,它接受A
和B
.如何将两个Stream
合并为Stream<C>
?
我有两条小溪,Stream<A>
和Stream<B>
.我有一个C
类型的构造函数,它接受A
和B
.如何将两个Stream
合并为Stream<C>
?
您可以使用package:async
中的StreamZip
将两个流合并为一个成对的流,然后从中创建C
个对象.
import "package:async" show StreamZip;
...
Stream<C> createCs(Stream<A> as, Stream<B> bs) =>
new StreamZip([as, bs]).map((ab) => new C(ab[0], ab[1]));