Package org.apache.pekko.stream.javadsl
Class ZipN$
- java.lang.Object
-
- org.apache.pekko.stream.javadsl.ZipN$
-
public class ZipN$ extends java.lang.Object
Combine the elements of multiple streams into a stream of lists.A
ZipN
has an
input ports and oneout
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 Description ZipN$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <A> Graph<UniformFanInShape<A,java.util.List<A>>,NotUsed>
create(int n)
-
-
-
Field Detail
-
MODULE$
public static final ZipN$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <A> Graph<UniformFanInShape<A,java.util.List<A>>,NotUsed> create(int n)
-
-