Class FixedSizePartitionHub<T>

    • 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 class PartitionHub<T>