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