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

Packages that use FlowControlledStream

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

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

Subclasses of FlowControlledStream 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 FlowControlledStream in io.axoniq.axonserver.connector.impl

Subclasses of FlowControlledStream 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.
class	AbstractIncomingInstructionStream<IN,OUT>	Abstract implementation of a FlowControlledStream for incoming message from AxonServer.
class	FlowControlledBuffer<T,R>	Abstract implementation of the FlowControlledStream, adding buffering logic to the flow controlled stream.

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

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

Modifier and Type	Class	Description
class	SubscriptionQueryStream	A FlowControlledStream implementation to return the results of a SubscriptionQuery.
class	SubscriptionQueryUpdateBuffer	Buffer for SubscriptionQuery updates.