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

WaitingFor

class WaitingFor(val stage: CommandStage, val contextName: String, val processorName: String = "") : WaitStrategy

Constructors

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

Types

object Companion

Properties

open override val contextName: String

open override val processorName: String

val stage: CommandStage

Functions

open override fun error(throwable: Throwable)

getContextAlias

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

isSameBoundedContext

open fun isSameBoundedContext(other: NamedBoundedContext): Boolean

open override fun next(signal: WaitSignal)

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

open override fun toString(): String

open override fun waiting(): Mono<WaitSignal>