Module io.axoniq.connector.axonserver

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

Class Summary

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