combineLatestList<T> method

Stream<List<T>> combineLatestList <T>(
  1. Iterable<Stream<T>> streams
)

Merges the given Streams into a single Stream that emits a List of the values emitted by the source Stream. This is helpful when you need to combine a dynamic number of Streams.

The Stream will not emit any lists of values until all of the source streams have emitted at least one value.

Interactive marble diagram

Example

Rx.combineLatestList([
  Stream.value(1),
  Stream.fromIterable([0, 1, 2]),
])
.listen(print); // prints [1, 0], [1, 1], [1, 2]

Implementation

static Stream<List<T>> combineLatestList<T>(Iterable<Stream<T>> streams) =>
    CombineLatestStream.list<T>(streams);