Uses of Interface
org.axonframework.messaging.core.AbstractMessageStream.FetchResult

Packages that use AbstractMessageStream.FetchResult

Package	Description
io.axoniq.framework.axonserver.connector.query	Part of the Axon Server Connector module.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.

Uses of AbstractMessageStream.FetchResult in io.axoniq.framework.axonserver.connector.query

Methods in io.axoniq.framework.axonserver.connector.query that return AbstractMessageStream.FetchResult

Modifier and Type	Method	Description
protected AbstractMessageStream.FetchResult<MessageStream.Entry<QueryResponseMessage>>	AbstractQueryResponseMessageStream.fetchNext()

Uses of AbstractMessageStream.FetchResult in org.axonframework.eventsourcing.eventstore

Methods in org.axonframework.eventsourcing.eventstore that return AbstractMessageStream.FetchResult

Modifier and Type	Method	Description
protected AbstractMessageStream.FetchResult<MessageStream.Entry<EventMessage>>	ContinuousMessageStream.fetchNext()

Uses of AbstractMessageStream.FetchResult in org.axonframework.messaging.core

Classes in org.axonframework.messaging.core that implement AbstractMessageStream.FetchResult

Modifier and Type	Class	Description
static final record	AbstractMessageStream.FetchResult.Completed<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult indicating that the stream is exhausted and no further elements will be produced.
static final record	AbstractMessageStream.FetchResult.Error<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult representing a terminal error in the stream.
static final record	AbstractMessageStream.FetchResult.NotReady<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult indicating that no element is currently available, but the stream may produce more elements in the future.
static final record	AbstractMessageStream.FetchResult.Value<T extends MessageStream.Entry<?>>	A AbstractMessageStream.FetchResult containing a successfully fetched value.

Methods in org.axonframework.messaging.core that return AbstractMessageStream.FetchResult

Modifier and Type	Method	Description
static <T extends MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.completed()	Returns a FetchResult indicating that no element is available and no further elements will be produced.
static <T extends MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.error(Throwable error)	Creates a FetchResult representing a producer side error.
protected abstract AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	AbstractMessageStream.fetchNext()	Attempts to fetch the next available MessageStream.Entry from the underlying source.
protected AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	CloseCallbackMessageStream.fetchNext()
protected AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	QueueMessageStream.fetchNext()
static <T extends MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.notReady()	Returns a FetchResult indicating that no element is currently available, but more elements may become available in the future.
static <T extends @Nullable MessageStream.Entry<?>> AbstractMessageStream.FetchResult<T>	AbstractMessageStream.FetchResult.of(@Nullable T value)	Creates a FetchResult representing a successfully fetched value.
static <M extends Message> AbstractMessageStream.FetchResult<MessageStream.Entry<M>>	AbstractMessageStream.FetchResult.of(MessageStream<M> delegate)	Creates a FetchResult reflecting the current observable state of the given MessageStream.

Methods in org.axonframework.messaging.core with parameters of type AbstractMessageStream.FetchResult

Modifier and Type	Method	Description
protected final void	AbstractMessageStream.initialize(AbstractMessageStream.FetchResult<MessageStream.Entry<M>> initialFetchResult)	This method can be used after the super constructor call completes in a subtype to set the initial state of the stream.