CombineLatestStream<T, R> constructor

CombineLatestStream<T, R>(
  1. Iterable<Stream<T>> streams,
  2. R combiner(
    1. List<T> values
    )
)

Constructs a Stream that observes an Iterable of Stream and builds a List containing all latest events emitted by the provided Iterable of Stream. The combiner maps this List into a new event of type R

Implementation

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