combineLatestList<T> static 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.

If the provided streams is empty, the resulting sequence completes immediately without emitting any items.

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