wow-core/me.ahoo.wow.command.wait/CommandWaitNotifierSubscriber

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>

Constructors

CommandWaitNotifierSubscriber

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

Properties

open override val isDisposed: Boolean

Functions

fun cancel()

open override fun currentContext(): Context

open fun dispose()

fun onComplete()

fun onError(t: Throwable?)

fun onNext(value: Void?)

fun onSubscribe(s: Subscription?)

fun request(n: Long)

requestUnbounded

fun requestUnbounded()