forkJoin8<A, B, C, D, E, F, G, H, T> static method
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.forkJoin8(
Stream.value('a'),
Stream.value('b'),
Stream.value('c'),
Stream.value('d'),
Stream.value('e'),
Stream.value('f'),
Stream.value('g'),
Stream.fromIterable(['h', 'i']),
(a, b, c, d, e, f, g, h) => a + b + c + d + e + f + g + h)
.listen(print); //prints 'abcdefgi'
Implementation
static Stream<T> forkJoin8<A, B, C, D, E, F, G, H, 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,
T Function(A a, B b, C c, D d, E e, F f, G g, H h) combiner) =>
ForkJoinStream.combine8(
streamA,
streamB,
streamC,
streamD,
streamE,
streamF,
streamG,
streamH,
combiner,
);