CommandWaitNotifierSubscriber
constructor(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitPlan: ExtractedWaitPlan, messageExchange: E, actual: CoreSubscriber<in Void>)
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.