forkJoinList<T> method

Observable<List<T>> forkJoinList<T>(
  1. Iterable<Stream<T>> streams
)

Merges the given Streams into one Observable that emits a List of the last values emitted by the source stream(s). This is helpful when you need to forkJoin a dynamic number of Streams.

Example

Observable.forkJoinList([
  Observable.just(1),
  Observable.fromIterable([0, 1, 2]),
])
.listen(print); // prints [1, 2]

Implementation

static Observable<List<T>> forkJoinList<T>(Iterable<Stream<T>> streams) =>
    Observable<List<T>>(ForkJoinStream.list<T>(streams));