akka.stream.impl

Interface Buffer<T>

All Known Implementing Classes:

BoundedBuffer, FixedSizeBuffer.FixedSizeBuffer, FixedSizeBuffer.ModuloFixedSizeBuffer, FixedSizeBuffer.PowerOfTwoFixedSizeBuffer

public interface Buffer<T>

INTERNAL API

Method Summary

Modifier and Type	Method and Description
int	capacity()
void	clear()
T	dequeue()
void	dropHead()
void	dropTail()
void	enqueue(T elem)
boolean	isEmpty()
boolean	isFull()
boolean	nonEmpty()
T	peek()
int	used()

Method Detail

capacity

int capacity()

used

int used()

isFull

boolean isFull()

isEmpty

boolean isEmpty()

nonEmpty

boolean nonEmpty()

enqueue

void enqueue(T elem)

dequeue

T dequeue()

peek

T peek()

clear

void clear()

dropHead

void dropHead()

dropTail

void dropTail()