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

Packages that use CloseableBuffer

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

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

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

Constructor	Description
BufferingReplyChannel(ReplyChannel<T> delegate, CloseableBuffer<T> buffer)	Instantiates this BufferingReplyChannel with given delegate and buffer.

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

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

Modifier and Type	Class	Description
class	BlockingCloseableBuffer<T>	An implementation of the CloseableBuffer that uses a LinkedBlockingQueue as the backing buffer.