6.0.6

wow-core/me.ahoo.wow.command.wait.chain/SimpleWaitingForChain

SimpleWaitingForChain

class SimpleWaitingForChain(val waitCommandId: String, val materialized: SimpleWaitingChain) : WaitingFor

Constructors

SimpleWaitingForChain

constructor(waitCommandId: String, materialized: SimpleWaitingChain)

Types

object Companion

Properties

open override val cancelled: Boolean

open override val completed: Boolean

open override val materialized: SimpleWaitingChain

supportVoidCommand

open override val supportVoidCommand: Boolean = false

是否支持虚空命令

open override val terminated: Boolean

open override val waitCommandId: String

Functions

open override fun complete()

open override fun error(throwable: Throwable)

isPreviousSignal

open override fun isPreviousSignal(signal: WaitSignal): Boolean

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

open override 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>