WaitingForProjected

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

Constructors

Link copied to clipboard
constructor(contextName: String, processorName: String = "")

Properties

Link copied to clipboard
open override val cancelled: Boolean
Link copied to clipboard
open override val contextName: String
Link copied to clipboard
open override val processorName: String
Link copied to clipboard
open override val stage: CommandStage
Link copied to clipboard
open override val terminated: Boolean

Functions

Link copied to clipboard
open override fun complete()
Link copied to clipboard
open override fun error(throwable: Throwable)
Link copied to clipboard
fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String
Link copied to clipboard
Link copied to clipboard
open override fun isWaitingForSignal(signal: WaitSignal): Boolean
Link copied to clipboard
open override fun next(signal: WaitSignal)

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

Link copied to clipboard
open override fun onFinally(doFinally: Consumer<SignalType>)
Link copied to clipboard
open override fun waiting(): Flux<WaitSignal>
Link copied to clipboard
open override fun waitingLast(): Mono<WaitSignal>