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 intcapacity()voidclear()Tdequeue()voiddropHead()voiddropTail()voidenqueue(T elem)booleanisEmpty()booleanisFull()booleannonEmpty()booleannonFull()Tpeek()protected longreadIdx()protected voidreadIdx_$eq(long x$1)intremainingCapacity()protected abstract inttoOffset(long idx, boolean maintenance)java.lang.StringtoString()intused()protected longwriteIdx()protected voidwriteIdx_$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:
toStringin classjava.lang.Object
-
writeIdx
protected long writeIdx()
-
writeIdx_$eq
protected void writeIdx_$eq(long x$1)
-
-