如何将多个流合并为更高级别的流? [英] How can I merge multiple Streams into a higher level Stream?

问题描述

我有两个流，Stream 和 Stream.我有一个 C 类型的构造函数，它接受一个 A 和一个 B.如何将两个 Stream 合并成一个 Stream?

I have two streams, Stream<A> and Stream<B>. I have a constructor for a type C that takes an A and a B. How do I merge the two Streams into a Stream<C>?

推荐答案

您可以在 package:async 中使用 StreamZip 将两个流组合成一对流，然后从中创建 C 对象.

You can use StreamZip in package:async to combine two streams into one stream of pairs, then create the C objects from that.

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]));

这篇关于如何将多个流合并为更高级别的流?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！