Package akka.stream.impl
Class FixedSizeBuffer
- java.lang.Object
-
- akka.stream.impl.FixedSizeBuffer
-
public class FixedSizeBuffer extends java.lang.Object
INTERNAL API
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
FixedSizeBuffer.ModuloFixedSizeBuffer<T>
static class
FixedSizeBuffer.PowerOfTwoFixedSizeBuffer<T>
-
Constructor Summary
Constructors Constructor Description FixedSizeBuffer()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> FixedSizeBuffer$FixedSizeBuffer<T>
apply(int size)
INTERNAL API
-
-
-
Method Detail
-
apply
public static <T> FixedSizeBuffer$FixedSizeBuffer<T> apply(int size)
INTERNAL APIReturns a fixed size buffer backed by an array. The buffer implementation DOES NOT check against overflow or underflow, it is the responsibility of the user to track or check the capacity of the buffer before enqueueing dequeueing or dropping.
Returns a specialized instance for power-of-two sized buffers.
-
-