6.0.6

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

WaitingFor

abstract class WaitingFor : WaitStrategy

Inheritors

SimpleWaitingForChain

WaitingForStage

Constructors

constructor()

Types

object Companion

object EmptyOnFinally : Consumer<SignalType>

Properties

open override val cancelled: Boolean

open override val completed: Boolean

abstract val materialized: WaitStrategy.Materialized

supportVoidCommand

open override val supportVoidCommand: Boolean = false

是否支持虚空命令

open override val terminated: Boolean

abstract val waitCommandId: String

Functions

open override fun complete()

open override fun error(throwable: Throwable)

isPreviousSignal

abstract fun isPreviousSignal(signal: WaitSignal): Boolean

判断给定的等待信号是否为前置信号

abstract fun next(signal: WaitSignal)

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

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

open override fun propagate(commandWaitEndpoint: String, header: Header)

执行传播操作

open override fun waiting(): Flux<WaitSignal>

open override fun waitingLast(): Mono<WaitSignal>