Uses of Interface
org.axonframework.messaging.core.MessageStream.Single
Packages that use MessageStream.Single
Package
Description
Classes that implement the concept of command handling using explicit command objects.
Classes related to message processing in Axon Framework.
-
Uses of MessageStream.Single in org.axonframework.messaging.commandhandling
Methods in org.axonframework.messaging.commandhandling that return MessageStream.SingleModifier and TypeMethodDescriptionCommandHandler.handle(CommandMessage command, ProcessingContext context) Handles the givencommandwithin the givencontext.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.SingleModifier and TypeMethodDescriptionAnnotatedCommandHandlingComponent.handle(CommandMessage command, ProcessingContext processingContext) -
Uses of MessageStream.Single in org.axonframework.messaging.core
Subinterfaces of MessageStream.Single in org.axonframework.messaging.coreModifier and TypeInterfaceDescriptionstatic interfaceMessageStream.Empty<M extends Message>AMessageStreamimplementation that completes normally or with an error without returning any elements.Methods in org.axonframework.messaging.core that return MessageStream.SingleModifier and TypeMethodDescriptionstatic <M extends Message>
MessageStream.Single<M> MonoUtils.asSingle(reactor.core.publisher.Mono<M> mono) Create a stream that returns a singlewrapping theinvalid reference
entryMessagefrom the givenmono, once the givenmonocompletes.static <M extends Message>
MessageStream.Single<M> Create a stream that returns a singlewrapping theinvalid reference
entryMessagefrom the givenmono, once the givenmonocompletes.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 asingle streamthat delays actions to itsdelegatewhen it becomes available.default MessageStream.Single<M> MessageStream.Single.filter(Predicate<MessageStream.Entry<M>> filter) default MessageStream.Single<M> MessageStream.first()Returns astreamthat includes only the first message ofthisstream, 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) static <M extends Message>
MessageStream.Single<M> MessageStream.fromFuture(CompletableFuture<M> future, Function<M, Context> contextSupplier) static <M extends Message>
MessageStream.Single<M> MessageStream.just(M message) Create a stream containing the single givenmessage, automatically wrapped in anMessageStream.Entry.static <M extends Message>
MessageStream.Single<M> Create a stream containing the single givenmessage, automatically wrapped in anMessageStream.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.SingleModifier and TypeMethodDescriptionstatic <M extends Message>
MessageStream.Single<M> DelayedMessageStream.createSingle(CompletableFuture<MessageStream.Single<M>> delegate) Creates asingle streamthat delays actions to itsdelegatewhen it becomes available. -
Uses of MessageStream.Single in org.axonframework.modelling.entity
Methods in org.axonframework.modelling.entity that return MessageStream.SingleModifier and TypeMethodDescriptionEntityCommandHandler.handle(CommandMessage command, E entity, ProcessingContext context) Handles the givenCommandMessagefor the givenentity.EntityCommandHandlingComponent.handle(CommandMessage command, ProcessingContext context) ConcreteEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context) EntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context) Handles the givenCommandMessageas the creation of a new entity.PolymorphicEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context) ConcreteEntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context) EntityMetamodel.handleInstance(CommandMessage message, E entity, ProcessingContext context) Handles the givenCommandMessagefor the givenentity.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.SingleModifier and TypeMethodDescriptionAnnotatedEntityMetamodel.handleCreate(CommandMessage message, ProcessingContext context) 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.SingleModifier and TypeMethodDescriptionAbstractEntityChildMetamodel.handle(CommandMessage message, P parentEntity, ProcessingContext context) EntityChildMetamodel.handle(CommandMessage message, P parentEntity, ProcessingContext context) Handles the givenCommandMessagefor the given child entity, using the provided parent entity.