Uses of Interface
io.axoniq.axonserver.connector.impl.CloseableReadonlyBuffer

Packages that use CloseableReadonlyBuffer

Package	Description
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.connector.impl.buffer

Uses of CloseableReadonlyBuffer in io.axoniq.axonserver.connector.impl

Subinterfaces of CloseableReadonlyBuffer in io.axoniq.axonserver.connector.impl

Modifier and Type	Interface	Description
interface	CloseableBuffer<T>	A buffer that can be closed by the producing side.
interface	DisposableReadonlyBuffer<T>	A buffer that can be disposed of from the subscriber's side.

Uses of CloseableReadonlyBuffer in io.axoniq.axonserver.connector.impl.buffer

Classes in io.axoniq.axonserver.connector.impl.buffer that implement CloseableReadonlyBuffer

Modifier and Type	Class	Description
class	BlockingCloseableBuffer<T>	An implementation of the CloseableBuffer that uses a LinkedBlockingQueue as the backing buffer.
class	FlowControlledDisposableReadonlyBuffer<T>	Connects a FlowControl instance with a DisposableReadonlyBuffer assuming that requesting from the flow control will trigger a replenishment of the buffer.
class	RoundRobinMultiReadonlyBuffer<T>	An implementation of the DisposableReadonlyBuffer that operates across multiple DisposableReadonlyBuffer instances.

Constructors in io.axoniq.axonserver.connector.impl.buffer with parameters of type CloseableReadonlyBuffer

Constructor	Description
FlowControlledDisposableReadonlyBuffer(FlowControl flowControl, CloseableReadonlyBuffer<T> buffer)	Instantiates this buffer with the given flowControl and buffer.