forkJoin3<A, B, C, T> static method

Stream<T> forkJoin3<A, B, C, T>(
  1. Stream<A> streamA,
  2. Stream<B> streamB,
  3. Stream<C> streamC,
  4. T combiner(
    1. A a,
    2. B b,
    3. C c
    ),
)

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.forkJoin3(
  Stream.value('a'),
  Stream.value('b'),
  Stream.fromIterable(['c', 'd']),
  (a, b, c) => a + b + c)
.listen(print); //prints 'abd'

Implementation

static Stream<T> forkJoin3<A, B, C, T>(Stream<A> streamA, Stream<B> streamB,
        Stream<C> streamC, T Function(A a, B b, C c) combiner) =>
    ForkJoinStream.join3(streamA, streamB, streamC, combiner);