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,
) : super(_buildController(streams, combiner).stream);