Uses of Class
io.axoniq.axonserver.connector.impl.FlowControlledBuffer

Packages that use FlowControlledBuffer

Package	Description
io.axoniq.axonserver.connector.event.impl
io.axoniq.axonserver.connector.impl
io.axoniq.axonserver.connector.query.impl

Uses of FlowControlledBuffer in io.axoniq.axonserver.connector.event.impl

Subclasses of FlowControlledBuffer in io.axoniq.axonserver.connector.event.impl

Modifier and Type	Class	Description
class	BufferedAggregateEventStream	Buffering implementation of the AggregateEventStream used for Event Sourced Aggregates.
class	BufferedEventStream	Buffering implementation of the EventStream used for Event processing.
class	BufferedPersistentStreamSegment	Implementation of the PersistentStreamSegment.

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

Subclasses of FlowControlledBuffer in io.axoniq.axonserver.connector.impl

Modifier and Type	Class	Description
class	AbstractBufferedStream<T,R>	An abstract FlowControlledBuffer and ResultStream implementation, used to provide a buffered stream of results of T when receiving a request of type R.

Uses of FlowControlledBuffer in io.axoniq.axonserver.connector.query.impl

Subclasses of FlowControlledBuffer in io.axoniq.axonserver.connector.query.impl

Modifier and Type	Class	Description
class	SubscriptionQueryUpdateBuffer	Buffer for SubscriptionQuery updates.