Package akka.stream.scaladsl
Class ZipWithN<A,O>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<UniformFanInShape<A,O>>
-
- akka.stream.scaladsl.ZipWithN<A,O>
-
- All Implemented Interfaces:
Graph<UniformFanInShape<A,O>,NotUsed>
- Direct Known Subclasses:
ZipN
public class ZipWithN<A,O> extends GraphStage<UniformFanInShape<A,O>>
Combine the elements of multiple streams into a stream of sequences using a combiner function.A
ZipWithN
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>
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description static <A,O>
ZipWithN<A,O>apply(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper, int n)
Create a newZipWithN
.GraphStageLogic
createLogic(Attributes inheritedAttributes)
Attributes
initialAttributes()
scala.collection.immutable.IndexedSeq<Inlet<A>>
inSeq()
Deprecated.use `shape.inlets` or `shape.in(id)` instead.Outlet<O>
out()
UniformFanInShape<A,O>
shape()
The shape of a graph is all that is externally visible: its inlets and outlets.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,O> ZipWithN<A,O> apply(scala.Function1<scala.collection.immutable.Seq<A>,O> zipper, int n)
Create a newZipWithN
.
-
initialAttributes
public Attributes initialAttributes()
- Overrides:
initialAttributes
in classGraphStageWithMaterializedValue<UniformFanInShape<A,O>,NotUsed>
-
shape
public UniformFanInShape<A,O> shape()
Description copied from interface:Graph
The shape of a graph is all that is externally visible: its inlets and outlets.
-
inSeq
public scala.collection.immutable.IndexedSeq<Inlet<A>> inSeq()
Deprecated.use `shape.inlets` or `shape.in(id)` instead. Since 2.5.5.
-
createLogic
public GraphStageLogic createLogic(Attributes inheritedAttributes)
- Specified by:
createLogic
in classGraphStage<UniformFanInShape<A,O>>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-