5.11.4

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

WaitingForProjected

class WaitingForProjected(val contextName: String, val processorName: String = "") : WaitingForAfterProcessed

Constructors

WaitingForProjected

constructor(contextName: String, processorName: String = "")

Properties

open override val cancelled: Boolean

open override val contextName: String

open override val processorName: String

open override val stage: CommandStage

open override val terminated: Boolean

Functions

open override fun complete()

open override fun error(throwable: Throwable)

getContextAlias

fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String

getContextAliasPrefix

fun NamedBoundedContext.getContextAliasPrefix(): String

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

isWaitingForSignal

open override fun isWaitingForSignal(signal: WaitSignal): Boolean

open override fun next(signal: WaitSignal)

由下游(CommandBus or Aggregate or Projector)发送处理结果信号.

open override fun onFinally(doFinally: Consumer<SignalType>)

open override fun waiting(): Flux<WaitSignal>

open override fun waitingLast(): Mono<WaitSignal>