Package akka.stream.scaladsl
Class PartitionHub.Internal$.PartitionQueueImpl
- java.lang.Object
-
- akka.stream.scaladsl.PartitionHub.Internal$.PartitionQueueImpl
-
- Enclosing class:
- PartitionHub.Internal$
public class PartitionHub.Internal$.PartitionQueueImpl extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description PartitionQueueImpl()
-
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()
-
-
-
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()
-
-