forkJoin7<A, B, C, D, E, F, G, T> method

Observable<T> forkJoin7 <A, B, C, D, E, F, G, T>(
  1. Stream<A> streamA,
  2. Stream<B> streamB,
  3. Stream<C> streamC,
  4. Stream<D> streamD,
  5. Stream<E> streamE,
  6. Stream<F> streamF,
  7. Stream<G> streamG,
  8. T combiner(
    1. A a,
    2. B b,
    3. C c,
    4. D d,
    5. E e,
    6. F f,
    7. G g

Merges the given Streams into one Observable sequence by using the combiner function when all of the observable sequences emits their last item.


  new Observable.just("a"),
  new Observable.just("b"),
  new Observable.just("c"),
  new Observable.just("d"),
  new Observable.just("e"),
  new Observable.just("f"),
  new Observable.fromIterable(["g", "h"]),
  (a, b, c, d, e, f, g) => a + b + c + d + e + f + g)
.listen(print); //prints "abcdefh"


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