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

Packages that use DisposableReadonlyBuffer

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

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

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

Constructor	Description
FlowControlledReplyChannelWriter(DisposableReadonlyBuffer<T> source, ReplyChannel<T> destination)	Instantiates this flow control with the given DisposableReadonlyBuffer as source, and a ReplyChannel as the destination.

Constructor parameters in io.axoniq.axonserver.connector.impl with type arguments of type DisposableReadonlyBuffer

Constructor	Description
FlowControlledReplyChannelWriter(List<? extends DisposableReadonlyBuffer<T>> sources, ReplyChannel<T> destination)	Instantiates this flow control with given buffers as sources, and ReplyChannel as the destination.

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

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

Modifier and Type	Class	Description
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.

Constructor parameters in io.axoniq.axonserver.connector.impl.buffer with type arguments of type DisposableReadonlyBuffer

Constructor	Description
RoundRobinMultiReadonlyBuffer(List<? extends DisposableReadonlyBuffer<T>> buffers)	Instantiates this buffer with a list of delegates.