forkJoin4<A, B, C, D, T> method
- Stream<
A> streamA, - Stream<
B> streamB, - Stream<
C> streamC, - Stream<
D> streamD, - T combiner(
- A a,
- B b,
- C c,
- D d
Merges the given Streams into one Observable sequence by using the
combiner
function when all of the observable sequences emits their
last item.
Example
Observable.forkJoin4(
new Observable.just("a"),
new Observable.just("b"),
new Observable.just("c"),
new Observable.fromIterable(["d", "e"]),
(a, b, c, d) => a + b + c + d)
.listen(print); //prints "abce"
Implementation
static Observable<T> forkJoin4<A, B, C, D, T>(
Stream<A> streamA,
Stream<B> streamB,
Stream<C> streamC,
Stream<D> streamD,
T combiner(A a, B b, C c, D d)) =>
Observable<T>(ForkJoinStream.combine4(
streamA, streamB, streamC, streamD, combiner));