forkJoin2<A, B, T> method
- Stream<
A> streamA, - Stream<
B> streamB, - T combiner(
- A a,
- B b
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.forkJoin2(
new Observable.just(1),
new Observable.fromIterable([0, 1, 2]),
(a, b) => a + b)
.listen(print); //prints 3
Implementation
static Observable<T> forkJoin2<A, B, T>(
Stream<A> streamA, Stream<B> streamB, T combiner(A a, B b)) =>
Observable<T>(ForkJoinStream.combine2(streamA, streamB, combiner));