Package akka.stream.scaladsl
Class Partition<T>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<UniformFanOutShape<T,T>>
-
- akka.stream.scaladsl.Partition<T>
-
- All Implemented Interfaces:
Graph<UniformFanOutShape<T,T>,NotUsed>
public final class Partition<T> extends GraphStage<UniformFanOutShape<T,T>>
SetseagerCancel
tofalse
.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
Partition.PartitionOutOfBoundsException
static class
Partition.PartitionOutOfBoundsException$
-
Constructor Summary
Constructors Constructor Description Partition(int outputPorts, scala.Function1<T,java.lang.Object> partitioner)
Deprecated.Use the constructor which also specifies the `eagerCancel` parameter.Partition(int outputPorts, scala.Function1<T,java.lang.Object> partitioner, boolean eagerCancel)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <T> Partition<T>
apply(int outputPorts, scala.Function1<T,java.lang.Object> partitioner)
GraphStageLogic
createLogic(Attributes inheritedAttributes)
boolean
eagerCancel()
Inlet<T>
in()
scala.collection.Seq<Outlet<T>>
out()
int
outputPorts()
scala.Function1<T,java.lang.Object>
partitioner()
UniformFanOutShape<T,T>
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
createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes
-
-
-
-
Constructor Detail
-
Partition
public Partition(int outputPorts, scala.Function1<T,java.lang.Object> partitioner, boolean eagerCancel)
-
Partition
public Partition(int outputPorts, scala.Function1<T,java.lang.Object> partitioner)
Deprecated.Use the constructor which also specifies the `eagerCancel` parameter. Since 2.5.10.
-
-
Method Detail
-
apply
public static <T> Partition<T> apply(int outputPorts, scala.Function1<T,java.lang.Object> partitioner)
-
outputPorts
public int outputPorts()
-
partitioner
public scala.Function1<T,java.lang.Object> partitioner()
-
eagerCancel
public boolean eagerCancel()
-
shape
public UniformFanOutShape<T,T> shape()
Description copied from interface:Graph
The shape of a graph is all that is externally visible: its inlets and outlets.- Returns:
- (undocumented)
-
createLogic
public GraphStageLogic createLogic(Attributes inheritedAttributes)
- Specified by:
createLogic
in classGraphStage<UniformFanOutShape<T,T>>
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-