akka.stream.impl

Class FixedSizeBuffer.ModuloFixedSizeBuffer<T>

java.lang.Object

akka.stream.impl.FixedSizeBuffer.FixedSizeBuffer<T>

akka.stream.impl.FixedSizeBuffer.ModuloFixedSizeBuffer<T>

All Implemented Interfaces:

Buffer<T>

Enclosing class:

FixedSizeBuffer

public static final class FixedSizeBuffer.ModuloFixedSizeBuffer<T>
extends FixedSizeBuffer.FixedSizeBuffer<T>

Constructor Summary

Constructors

Constructor and Description
ModuloFixedSizeBuffer(int _size)

Method Summary

Modifier and Type	Method and Description
protected int	toOffset(long idx, boolean maintenance)

Methods inherited from class akka.stream.impl.FixedSizeBuffer.FixedSizeBuffer

capacity, clear, dequeue, dropHead, dropTail, enqueue, isEmpty, isFull, nonEmpty, peek, readIdx, toString, used, writeIdx

Methods inherited from class java.lang.Object

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

Constructor Detail

ModuloFixedSizeBuffer

public ModuloFixedSizeBuffer(int _size)

Method Detail

toOffset

protected int toOffset(long idx,
                       boolean maintenance)

Specified by:

toOffset in class FixedSizeBuffer.FixedSizeBuffer<T>