forkJoin6<A, B, C, D, E, F, T> method

Observable<T> forkJoin6 <A, B, C, D, E, F, T>(Stream<A> streamA, Stream<B> streamB, Stream<C> streamC, Stream<D> streamD, Stream<E> streamE, Stream<F> streamF, T combiner(A a, B b, C c, D d, E e, F f))

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.forkJoin6(
  new Observable.just("a"),
  new Observable.just("b"),
  new Observable.just("c"),
  new Observable.just("d"),
  new Observable.just("e"),
  new Observable.fromIterable(["f", "g"]),
  (a, b, c, d, e, f) => a + b + c + d + e + f)
.listen(print); //prints "abcdeg"

Implementation

static Observable<T> forkJoin6<A, B, C, D, E, F, T>(
        Stream<A> streamA,
        Stream<B> streamB,
        Stream<C> streamC,
        Stream<D> streamD,
        Stream<E> streamE,
        Stream<F> streamF,
        T combiner(A a, B b, C c, D d, E e, F f)) =>
    Observable<T>(ForkJoinStream.combine6(
        streamA, streamB, streamC, streamD, streamE, streamF, combiner));