CommandWaitNotifierSubscriber
class CommandWaitNotifierSubscriber<E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitPlan: ExtractedWaitPlan, messageExchange: E, actual: CoreSubscriber<in Void>) : BaseSubscriber<Void>
Subscriber that handles command processing completion and sends wait notifications. This subscriber wraps the actual subscriber and intercepts completion/error events to send appropriate wait signals to waiting clients.
Parameters
commandWaitNotifier
The notifier for sending wait signals.
processingStage
The stage of processing being completed.
waitPlan
The extracted wait plan containing notification details.
messageExchange
The message exchange with processing context.
actual
The actual subscriber to delegate completion events to.
Type Parameters
E
The type of message exchange.
M
The type of message in the exchange.
Constructors
Link copied to clipboard
constructor(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitPlan: ExtractedWaitPlan, messageExchange: E, actual: CoreSubscriber<in Void>)