forkJoin2<A, B, T> method

Observable<T> forkJoin2 <A, B, T>(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));