forkJoin2<A, B, T> method

Observable<T> forkJoin2 <A, B, T>(
  1. Stream<A> streamA,
  2. Stream<B> streamB,
  3. T combiner(
    1. A a,
    2. 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));