combineLatest7<A, B, C, D, E, F, G, T> method
- 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
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.
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));