wow-core/me.ahoo.wow.command.wait/MonoCommandWaitNotifier

MonoCommandWaitNotifier

class MonoCommandWaitNotifier<E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, messageExchange: E, source: Mono<Void>) : Mono<Void>

A Mono wrapper that automatically notifies wait plans when command processing completes. This class intercepts the completion of a Mono operation and sends appropriate wait signals based on the processing stage and message exchange.

Parameters

commandWaitNotifier

The notifier used to send wait signals.

processingStage

The command processing stage being notified.

messageExchange

The message exchange containing processing context.

source

The original Mono operation to wrap.

Type Parameters

The type of message exchange.

The type of message in the exchange.

Constructors

MonoCommandWaitNotifier

constructor(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, messageExchange: E, source: Mono<Void>)

Functions

open override fun subscribe(actual: CoreSubscriber<in Void>)