6.0.6

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

WaitStrategy

interface WaitStrategy : WaitCommandIdCapable, WaitStrategyPropagator, CompletedCapable

Command Wait Strategy

See also

WaitingForStage

Inheritors

Types

FunctionMaterialized

interface FunctionMaterialized : WaitStrategy.Materialized, CommandStageCapable, NullableFunctionInfoCapable<NamedFunctionInfoData>

interface Materialized : ProcessingStageShouldNotifyPredicate, WaitSignalShouldNotifyPredicate, Materialized, WaitStrategyPropagator, MessagePropagator

Properties

abstract val cancelled: Boolean

open override val completed: Boolean

abstract val materialized: WaitStrategy.Materialized

supportVoidCommand

abstract val supportVoidCommand: Boolean

是否支持虚空命令

abstract val terminated: Boolean

abstract val waitCommandId: String

Functions

abstract fun complete()

abstract fun error(throwable: Throwable)

abstract fun next(signal: WaitSignal)

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

abstract fun onFinally(doFinally: Consumer<SignalType>)

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

执行传播操作

abstract fun waiting(): Flux<WaitSignal>

abstract fun waitingLast(): Mono<WaitSignal>