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

Observable<T> combineLatest7<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 whenever any of the observable sequences emits an item.

The Observable will not emit until all streams have emitted at least one item.

Interactive marble diagram

Example

Observable.combineLatest7(
  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", "g"]),
  (a, b, c, d, e, f, g) => a + b + c + d + e + f + g)
.listen(print); //prints "abcdefg", "abcdefg"

Implementation

static Observable<T> combineLatest7<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>(CombineLatestStream.combine7(streamA, streamB, streamC,
        streamD, streamE, streamF, streamG, combiner));