Package akka.stream.scaladsl
Class ZipN<A>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<UniformFanInShape<A,O>>
-
- akka.stream.scaladsl.ZipWithN<A,scala.collection.immutable.Seq<A>>
-
- akka.stream.scaladsl.ZipN<A>
-
- All Implemented Interfaces:
Graph<UniformFanInShape<A,scala.collection.immutable.Seq<A>>,NotUsed>
public final class ZipN<A> extends ZipWithN<A,scala.collection.immutable.Seq<A>>
Combine the elements of multiple streams into a stream of sequences.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
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.stream.Graph
Graph.GraphMapMatVal<S extends Shape,M>
-
-
Constructor Summary
Constructors Constructor Description ZipN(int n)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <A> ZipN<A>
apply(int n)
Create a newZipN
.Attributes
initialAttributes()
java.lang.String
toString()
-
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
withAttributes
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface akka.stream.Graph
addAttributes, async, async, async, getAttributes, named
-
-
-
-
Method Detail
-
apply
public static <A> ZipN<A> apply(int n)
Create a newZipN
.
-
initialAttributes
public Attributes initialAttributes()
- Overrides:
initialAttributes
in classZipWithN<A,scala.collection.immutable.Seq<A>>
-
-