Package akka.stream.impl
Class FixedSizeBuffer$FixedSizeBuffer<T>
- java.lang.Object
-
- akka.stream.impl.FixedSizeBuffer$FixedSizeBuffer<T>
-
- All Implemented Interfaces:
Buffer<T>
- Direct Known Subclasses:
FixedSizeBuffer.ModuloFixedSizeBuffer
,FixedSizeBuffer.PowerOfTwoFixedSizeBuffer
public abstract class FixedSizeBuffer$FixedSizeBuffer<T> extends java.lang.Object implements Buffer<T>
-
-
Constructor Summary
Constructors Constructor Description FixedSizeBuffer$FixedSizeBuffer(int capacity)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description int
capacity()
void
clear()
T
dequeue()
void
dropHead()
void
dropTail()
void
enqueue(T elem)
boolean
isEmpty()
boolean
isFull()
boolean
nonEmpty()
boolean
nonFull()
T
peek()
protected long
readIdx()
protected void
readIdx_$eq(long x$1)
int
remainingCapacity()
protected abstract int
toOffset(long idx, boolean maintenance)
java.lang.String
toString()
int
used()
protected long
writeIdx()
protected void
writeIdx_$eq(long x$1)
-
-
-
Method Detail
-
nonFull
public boolean nonFull()
-
readIdx
protected long readIdx()
-
readIdx_$eq
protected void readIdx_$eq(long x$1)
-
remainingCapacity
public int remainingCapacity()
-
toOffset
protected abstract int toOffset(long idx, boolean maintenance)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
writeIdx
protected long writeIdx()
-
writeIdx_$eq
protected void writeIdx_$eq(long x$1)
-
-