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

FunctionMaterialized

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

Inheritors

SimpleWaitingChain

WaitingChainTail

Properties

abstract val function: NamedFunctionInfoData?

abstract val stage: CommandStage

Functions

open override fun propagate(header: Header, upstream: Message<*, *>)

Propagates context information from an upstream message to the target header.

abstract fun propagate(commandWaitEndpoint: String, header: Header)

Executes propagation operation.

open override fun shouldNotify(processingStage: CommandStage): Boolean

Evaluates whether notification is required for the given processing stage. This allows wait strategies to filter notifications based on their waiting criteria.

open override fun shouldNotify(signal: WaitSignal): Boolean

Evaluates whether the wait signal should trigger a notification. Allows for complex filtering logic based on signal properties like stage, function info, error status, etc.

shouldPropagate

open fun shouldPropagate(upstream: Message<*, *>): Boolean

判断是否应该传播指定的消息