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
org.axonframework.messaging.core	Classes related to message processing in Axon Framework.
org.axonframework.modelling.entity
org.axonframework.modelling.entity.annotation
org.axonframework.modelling.entity.child

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(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(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.