CommandWaitNotifierSubscriber
constructor(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitStrategy: ExtractedWaitStrategy, messageExchange: E, actual: CoreSubscriber<in Void>)
Parameters
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.
Type Parameters
E
The type of message exchange.
M
The type of message in the exchange.