ZipStream<T, R> constructor

ZipStream<T, R>(
  1. Iterable<Stream<T>> streams,
  2. R zipper(
    1. List<T> values
    )
)

Constructs a Stream which merges the specified streams into a sequence using the given zipper Function, whenever all of the streams have produced an element at a corresponding index.

Implementation

ZipStream(
  Iterable<Stream<T>> streams,
  R Function(List<T> values) zipper,
)   : assert(streams != null && streams.every((s) => s != null),
          'streams cannot be null'),
      assert(zipper != null, 'must provide a zipper function'),
      super(_buildController(streams, zipper).stream);