CommandWaitNotifierSubscriber

class CommandWaitNotifierSubscriber<E : MessageExchange<*, M>, M : Message<*, *>, CommandId, NamedBoundedContext>(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitStrategy: WaitStrategyInfo, commandId: String, messageExchange: E, actual: CoreSubscriber<in Void>) : BaseSubscriber<Void>

Constructors

constructor(commandWaitNotifier: CommandWaitNotifier, processingStage: CommandStage, waitStrategy: WaitStrategyInfo, commandId: String, messageExchange: E, actual: CoreSubscriber<in Void>)

override fun cancel()

open override fun currentContext(): Context

open override fun dispose()

open override fun isDisposed(): Boolean

override fun onComplete()

override fun onError(p0: Throwable)

override fun onNext(p0: Void)

override fun onSubscribe(p0: Subscription)

override fun request(p0: Long)

open override fun toString(): String