Package akka.stream.javadsl
Class ZipN
- java.lang.Object
-
- akka.stream.javadsl.ZipN
-
public class ZipN extends java.lang.ObjectCombine the elements of multiple streams into a stream of lists.A
ZipNhas aninput ports and oneoutport'''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 Description ZipN()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <A> Graph<UniformFanInShape<A,java.util.List<A>>,NotUsed>create(int n)
-
-
-
Method Detail
-
create
public static <A> Graph<UniformFanInShape<A,java.util.List<A>>,NotUsed> create(int n)
-
-