akka.stream.javadsl

Class ZipN

java.lang.Object

akka.stream.javadsl.ZipN

public class ZipN
extends java.lang.Object

Combine the elements of multiple streams into a stream of lists.

A ZipN has a n input ports and one out port

'''Emits when''' all of the inputs has an element available

'''Backpressures when''' downstream backpressures

'''Completes when''' any upstream completes

'''Cancels when''' downstream cancels

Constructor Summary

Constructors

Constructor and Description
ZipN()

Method Summary

Modifier and Type	Method and Description
static <A> Graph<UniformFanInShape<A,java.util.List<A>>,NotUsed>	create(int n)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ZipN

public ZipN()

Method Detail

create

public static <A> Graph<UniformFanInShape<A,java.util.List<A>>,NotUsed> create(int n)