forkJoinList<T> method
- Iterable<
Stream< streamsT> >
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));