Package akka.stream.scaladsl

Class PartitionHub.Internal$.PartitionQueueImpl

  • Enclosing class:
    PartitionHub.Internal$
    public class PartitionHub.Internal$.PartitionQueueImpl
extends java.lang.Object

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void init​(long id)  
      boolean isEmpty​(long id)  
      boolean nonEmpty​(long id)  
      void offer​(long id, java.lang.Object elem)  
      java.lang.Object poll​(long id)  
      void remove​(long id)  
      int size​(long id)  
      int totalSize()  

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • PartitionQueueImpl

        public PartitionQueueImpl()

    • Method Detail

      • init

        public void init​(long id)

      • isEmpty

        public boolean isEmpty​(long id)

      • nonEmpty

        public boolean nonEmpty​(long id)

      • offer

        public void offer​(long id,
                  java.lang.Object elem)

      • poll

        public java.lang.Object poll​(long id)

      • remove

        public void remove​(long id)

      • size

        public int size​(long id)

      • totalSize

        public int totalSize()