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

WaitingChainTail

class WaitingChainTail(val stage: CommandStage, val function: NamedFunctionInfoData) : WaitStrategy.FunctionMaterialized

Represents the tail (final) stage in a waiting chain. This class encapsulates the final stage and function criteria that a waiting chain should wait for after completing the main processing stages.

Parameters

stage

The command processing stage to wait for.

function

The function criteria for the stage (may be empty for non-function stages).

Constructors

WaitingChainTail

constructor(stage: CommandStage, function: NamedFunctionInfoData)

Types

Companion

object Companion

Properties

function

open override val function: NamedFunctionInfoData

stage

open override val stage: CommandStage

Functions

propagate

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

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

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

Executes propagation operation.

shouldNotify

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

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

toWaitingChainTail

fun CommandStage.toWaitingChainTail(function: NamedFunctionInfoData = NamedFunctionInfoData.EMPTY): WaitingChainTail