Package akka.remote.artery
Class FixedSizePartitionHub<T>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<SinkShape<T>,Source<T,NotUsed>>
-
- akka.stream.scaladsl.PartitionHub<T>
-
- akka.remote.artery.FixedSizePartitionHub<T>
-
public class FixedSizePartitionHub<T> extends PartitionHub<T>
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.stream.scaladsl.PartitionHub
PartitionHub.ConsumerInfo, PartitionHub.Internal$
-
-
Constructor Summary
Constructors Constructor Description FixedSizePartitionHub(scala.Function1<T,java.lang.Object> partitioner, int lanes, int bufferSize)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description akka.stream.scaladsl.PartitionHub.Internal.PartitionQueue
createQueue()
-
Methods inherited from class akka.stream.scaladsl.PartitionHub
createLogicAndMaterializedValue, defaultBufferSize, in, shape, sink, sink$default$3, statefulSink, statefulSink$default$3
-
Methods inherited from class akka.stream.stage.GraphStageWithMaterializedValue
createLogicAndMaterializedValue, initialAttributes, traversalBuilder, withAttributes
-
-
-
-
Constructor Detail
-
FixedSizePartitionHub
public FixedSizePartitionHub(scala.Function1<T,java.lang.Object> partitioner, int lanes, int bufferSize)
-
-
Method Detail
-
createQueue
public akka.stream.scaladsl.PartitionHub.Internal.PartitionQueue createQueue()
- Overrides:
createQueue
in classPartitionHub<T>
-
-