Uses of Interface
org.axonframework.messaging.core.MessageStream.Single

Packages that use MessageStream.Single

Package	Description
org.axonframework.messaging.commandhandling	Classes that implement the concept of command handling using explicit command objects.
org.axonframework.messaging.commandhandling.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.modelling.entity	Part of the Axon Modelling module.
org.axonframework.modelling.entity.annotation	Part of the Axon Modelling module.
org.axonframework.modelling.entity.child	Part of the Axon Modelling module.

Uses of MessageStream.Single in org.axonframework.messaging.commandhandling

Methods in org.axonframework.messaging.commandhandling that return MessageStream.Single

Modifier and Type	Method	Description
MessageStream.Single<CommandResultMessage>	CommandHandler.handle(CommandMessage command, ProcessingContext context)	Handles the given command within the given context.
MessageStream.Single<CommandResultMessage>	SimpleCommandHandlingComponent.handle(CommandMessage command, ProcessingContext context)

Uses of MessageStream.Single in org.axonframework.messaging.commandhandling.annotation

Methods in org.axonframework.messaging.commandhandling.annotation that return MessageStream.Single

Modifier and Type	Method	Description
MessageStream.Single<CommandResultMessage>	AnnotatedCommandHandlingComponent.handle(CommandMessage command, ProcessingContext processingContext)

Uses of MessageStream.Single in org.axonframework.messaging.core

Subinterfaces of MessageStream.Single in org.axonframework.messaging.core

Modifier and Type	Interface	Description
static interface	MessageStream.Empty<M extends Message>	A MessageStream implementation that completes normally or with an error without returning any elements.

Methods in org.axonframework.messaging.core that return MessageStream.Single

Modifier and Type	Method	Description
static <M extends Message> MessageStream.Single<M>	MonoUtils.asSingle(reactor.core.publisher.Mono<M> mono)	Create a stream that returns a single invalid reference entry wrapping the Message from the given mono, once the given mono completes.
static <M extends Message> MessageStream.Single<M>	MonoUtils.asSingle(reactor.core.publisher.Mono<M> mono, Function<M,Context> contextSupplier)	Create a stream that returns a single invalid reference entry wrapping the Message from the given mono, once the given mono completes.
default <R extends Message> MessageStream.Single<R>	MessageStream.Single.cast()
static <M extends Message> MessageStream.Single<M>	DelayedMessageStream.createSingle(CompletableFuture<MessageStream.Single<M>> delegate)	Creates a single stream that delays actions to its delegate when it becomes available.
default MessageStream.Single<M>	MessageStream.Single.filter(Predicate<MessageStream.Entry<M>> filter)
default MessageStream.Single<M>	MessageStream.first()	Returns a stream that includes only the first message of this stream, unless it completes without delivering any messages, in which case it completes the same way.
default MessageStream.Single<M>	MessageStream.Single.first()
static <M extends Message> MessageStream.Single<M>	MessageStream.fromFuture(CompletableFuture<M> future)	Create a stream that returns a single entry wrapping the Message from the given future, once the given future completes.
static <M extends Message> MessageStream.Single<M>	MessageStream.fromFuture(CompletableFuture<M> future, Function<M,Context> contextSupplier)	Create a stream that returns a single entry wrapping the Message from the given future, once the given future completes.
static <M extends Message> MessageStream.Single<M>	MessageStream.just(@Nullable M message)	Create a stream containing the single given message, automatically wrapped in an MessageStream.Entry.
static <M extends Message> MessageStream.Single<M>	MessageStream.just(@Nullable M message, Function<M,Context> contextSupplier)	Create a stream containing the single given message, automatically wrapped in an MessageStream.Entry.
default <RM extends Message> MessageStream.Single<RM>	MessageStream.Single.map(Function<MessageStream.Entry<M>,MessageStream.Entry<RM>> mapper)
default <RM extends Message> MessageStream.Single<RM>	MessageStream.Single.mapMessage(Function<M,RM> mapper)
default MessageStream.Single<M>	MessageStream.Single.onComplete(Runnable completeHandler)
default MessageStream.Single<M>	MessageStream.Single.onNext(Consumer<MessageStream.Entry<M>> onNext)

Method parameters in org.axonframework.messaging.core with type arguments of type MessageStream.Single

Modifier and Type	Method	Description
static <M extends Message> MessageStream.Single<M>	DelayedMessageStream.createSingle(CompletableFuture<MessageStream.Single<M>> delegate)	Creates a single stream that delays actions to its delegate when it becomes available.

Uses of MessageStream.Single in org.axonframework.modelling.entity

Methods in org.axonframework.modelling.entity that return MessageStream.Single

Modifier and Type	Method	Description
MessageStream.Single<CommandResultMessage>	EntityCommandHandler.handle(CommandMessage command, E entity, ProcessingContext context)	Handles the given CommandMessage for the given entity.
MessageStream.Single<CommandResultMessage>	EntityCommandHandlingComponent.handle(CommandMessage command, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	ConcreteEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)	Handles the given CommandMessage as the creation of a new entity.
MessageStream.Single<CommandResultMessage>	PolymorphicEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	ConcreteEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)	Handles the given CommandMessage for the given entity.
MessageStream.Single<CommandResultMessage>	PolymorphicEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)

Uses of MessageStream.Single in org.axonframework.modelling.entity.annotation

Methods in org.axonframework.modelling.entity.annotation that return MessageStream.Single

Modifier and Type	Method	Description
MessageStream.Single<CommandResultMessage>	AnnotatedEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	AnnotatedEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context)

Uses of MessageStream.Single in org.axonframework.modelling.entity.child

Methods in org.axonframework.modelling.entity.child that return MessageStream.Single

Modifier and Type	Method	Description
MessageStream.Single<CommandResultMessage>	AbstractEntityChildMetamodel.handle(CommandMessage message, P parentEntity, ProcessingContext context)
MessageStream.Single<CommandResultMessage>	EntityChildMetamodel.handle(CommandMessage message, P parentEntity, ProcessingContext context)	Handles the given CommandMessage for the given child entity, using the provided parent entity.