CommandWaitNotifierSubscriber
class CommandWaitNotifierSubscriber<E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext, AggregateIdCapable>(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitStrategy: ExtractedWaitStrategy, 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
E
The type of message exchange.
M
The type of message in the exchange.
commandWaitNotifier
The notifier for sending wait signals.
processingStage
The stage of processing being completed.
waitStrategy
The extracted wait strategy containing notification details.
messageExchange
The message exchange with processing context.
actual
The actual subscriber to delegate completion events to.
Constructors
Link copied to clipboard
constructor(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitStrategy: ExtractedWaitStrategy, messageExchange: E, actual: CoreSubscriber<in Void>)