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 and Description
static class	FixedSizeBuffer.FixedSizeBuffer<T>
static class	FixedSizeBuffer.ModuloFixedSizeBuffer<T>
static class	FixedSizeBuffer.PowerOfTwoFixedSizeBuffer<T>

Constructor Summary

Constructors

Constructor and Description
FixedSizeBuffer()

Method Summary

Modifier and Type	Method and Description
static <T> <any>	apply(int size) INTERNAL API

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FixedSizeBuffer

public FixedSizeBuffer()

Method Detail

apply

public static <T> <any> apply(int size)

INTERNAL API

Returns 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.

Parameters:

size - (undocumented)

Returns:

(undocumented)