forkJoin9<A, B, C, D, E, F, G, H, I, T> static method

Stream<T> forkJoin9<A, B, C, D, E, F, G, H, I, 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. Stream<H> streamH,
  9. Stream<I> streamI,
  10. T combiner(
    1. A a,
    2. B b,
    3. C c,
    4. D d,
    5. E e,
    6. F f,
    7. G g,
    8. H h,
    9. I i,
    ),
)

Merges the given Streams into a single Stream sequence by using the combiner function when all of the stream sequences emits their last item.

Example

Rx.forkJoin9(
  Stream.value('a'),
  Stream.value('b'),
  Stream.value('c'),
  Stream.value('d'),
  Stream.value('e'),
  Stream.value('f'),
  Stream.value('g'),
  Stream.value('h'),
  Stream.fromIterable(['i', 'j']),
  (a, b, c, d, e, f, g, h, i) => a + b + c + d + e + f + g + h + i)
.listen(print); //prints 'abcdefghj'

Implementation

static Stream<T> forkJoin9<A, B, C, D, E, F, G, H, I, T>(
        Stream<A> streamA,
        Stream<B> streamB,
        Stream<C> streamC,
        Stream<D> streamD,
        Stream<E> streamE,
        Stream<F> streamF,
        Stream<G> streamG,
        Stream<H> streamH,
        Stream<I> streamI,
        T Function(A a, B b, C c, D d, E e, F f, G g, H h, I i) combiner) =>
    ForkJoinStream.join9(
      streamA,
      streamB,
      streamC,
      streamD,
      streamE,
      streamF,
      streamG,
      streamH,
      streamI,
      combiner,
    );