Package akka.stream.scaladsl

Interface PartitionHub.Internal$.PartitionQueue

Enclosing class:

PartitionHub.Internal$

public static interface PartitionHub.Internal$.PartitionQueue

Method Summary

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

void init(long id)

isEmpty

boolean isEmpty(long id)

nonEmpty

boolean nonEmpty(long id)

offer

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

poll

java.lang.Object poll(long id)

remove

void remove(long id)

size

int size(long id)

totalSize

int totalSize()