withLatestFrom8<A, B, C, D, E, F, G, H, R> method

Observable<R> withLatestFrom8<A, B, C, D, E, F, G, H, R>(
  1. Stream<A> latestFromStream1,
  2. Stream<B> latestFromStream2,
  3. Stream<C> latestFromStream3,
  4. Stream<D> latestFromStream4,
  5. Stream<E> latestFromStream5,
  6. Stream<F> latestFromStream6,
  7. Stream<G> latestFromStream7,
  8. Stream<H> latestFromStream8,
  9. R fn(
    1. T t,
    2. A a,
    3. B b,
    4. C c,
    5. D d,
    6. E e,
    7. F f,
    8. G g,
    9. H h
    )
)

Creates an Observable that emits when the source stream emits, combining the latest values from the nine streams using the provided function.

If any of latestFromStreams has not emitted any values, this stream will not emit either.

Interactive marble diagram

Example

Observable.fromIterable([1, 2])
  .withLatestFrom8(
    Observable.fromIterable([2, 3]),
    Observable.fromIterable([3, 4]),
    Observable.fromIterable([4, 5]),
    Observable.fromIterable([5, 6]),
    Observable.fromIterable([6, 7]),
    Observable.fromIterable([7, 8]),
    Observable.fromIterable([8, 9]),
    Observable.fromIterable([9, 10]),
    (int a, int b, int c, int d, int e, int f, int g, int h, int i) =>
        a + b + c + d + e + f + g + h + i,
  )
  .listen(print); // prints 46 (due to the async nature of streams)

Implementation

Observable<R> withLatestFrom8<A, B, C, D, E, F, G, H, R>(
  Stream<A> latestFromStream1,
  Stream<B> latestFromStream2,
  Stream<C> latestFromStream3,
  Stream<D> latestFromStream4,
  Stream<E> latestFromStream5,
  Stream<F> latestFromStream6,
  Stream<G> latestFromStream7,
  Stream<H> latestFromStream8,
  R fn(T t, A a, B b, C c, D d, E e, F f, G g, H h),
) =>
    transform(WithLatestFromStreamTransformer.with8(
      latestFromStream1,
      latestFromStream2,
      latestFromStream3,
      latestFromStream4,
      latestFromStream5,
      latestFromStream6,
      latestFromStream7,
      latestFromStream8,
      fn,
    ));