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

DomainEventDistributionSubscriber

inner class DomainEventDistributionSubscriber : SafeSubscriber<GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>>

Constructors

DomainEventDistributionSubscriber

constructor()

Properties

open override val name: String

Functions

override fun cancel()

open fun currentContext(): Context

open override fun dispose()

open override fun isDisposed(): Boolean

override fun onComplete()

override fun onError(p0: Throwable)

override fun onNext(p0: GroupedFlux<MaterializedNamedAggregate, EventStreamExchange>)

override fun onSubscribe(p0: Subscription)

override fun request(p0: Long)

requestUnbounded

fun requestUnbounded()

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

safeOnNextError

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

open override fun toString(): String