wow-core/me.ahoo.wow.event/AbstractEventDispatcher/StateEventDistributionSubscriber

StateEventDistributionSubscriber

inner class StateEventDistributionSubscriber : SafeSubscriber<GroupedFlux<MaterializedNamedAggregate, StateEventExchange<*>>>

Constructors

StateEventDistributionSubscriber

constructor()

Properties

open override val isDisposed: Boolean

open override val name: String

Functions

fun cancel()

open fun currentContext(): Context?

open fun dispose()

fun onComplete()

fun onError(t: Throwable?)

fun onNext(value: GroupedFlux<MaterializedNamedAggregate, StateEventExchange<*>>?)

fun onSubscribe(s: Subscription?)

fun request(n: Long)

requestUnbounded

fun requestUnbounded()

open override fun safeOnNext(value: GroupedFlux<MaterializedNamedAggregate, StateEventExchange<*>>)

safeOnNextError

open fun safeOnNextError(value: GroupedFlux<MaterializedNamedAggregate, StateEventExchange<*>>, throwable: Throwable)