Uses of Interface
org.axonframework.common.stream.BlockingStream

Packages that use BlockingStream

Package	Description
org.axonframework.axonserver.connector.event.axon
org.axonframework.common.stream
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.messaging	Classes related to message processing in Axon Framework.

Uses of BlockingStream in org.axonframework.axonserver.connector.event.axon

Classes in org.axonframework.axonserver.connector.event.axon that implement BlockingStream

Modifier and Type	Class	Description
class	EventBuffer	Client-side buffer of messages received from the server.

Uses of BlockingStream in org.axonframework.common.stream

Methods in org.axonframework.common.stream with parameters of type BlockingStream

Modifier and Type	Method	Description
static <M> Stream<M>	StreamUtils.asStream(BlockingStream<M> messageStream)	Convert the given messageStream to a regular java Stream.

Uses of BlockingStream in org.axonframework.eventhandling

Subinterfaces of BlockingStream in org.axonframework.eventhandling

Modifier and Type	Interface	Description
interface	TrackingEventStream	Describes a stream of TrackedEventMessages.

Uses of BlockingStream in org.axonframework.messaging

Methods in org.axonframework.messaging that return BlockingStream

Modifier and Type	Method	Description
BlockingStream<M>	StreamableMessageSource.openStream(TrackingToken trackingToken)	Open a stream containing all messages since given tracking token.