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

WaitingFor

abstract class WaitingFor : WaitStrategy

Abstract base class for wait strategies that wait for specific command processing stages. Provides common functionality for managing wait signals, completion, and error handling. Subclasses must implement the logic for determining which signals are relevant.

Inheritors

SimpleWaitingForChain

WaitingForStage

Constructors

WaitingFor

constructor()

Types

Companion

object Companion

EmptyOnFinally

object EmptyOnFinally : Consumer<SignalType>

Properties

cancelled

open override val cancelled: Boolean

completed

open override val completed: Boolean

materialized

abstract val materialized: WaitStrategy.Materialized

supportVoidCommand

open override val supportVoidCommand: Boolean = false

Whether this strategy supports void commands.

terminated

open override val terminated: Boolean

waitCommandId

abstract val waitCommandId: String

The unique identifier for the wait command. This ID is used to match wait strategies with command processing results.

Functions

complete

open override fun complete()

Marks the wait strategy as completed.

error

open override fun error(throwable: Throwable)

Signals an error occurred during command processing.

isPreviousSignal

abstract fun isPreviousSignal(signal: WaitSignal): Boolean

Determines if the given wait signal represents a prerequisite stage. Prerequisite signals are those that must complete before this wait strategy can consider its waiting condition satisfied.

abstract fun next(signal: WaitSignal)

Receives the next processing result signal from downstream processors.

onFinally

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

Registers a callback to be executed when the strategy completes.

propagate

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

执行传播操作

waiting

open override fun waiting(): Flux<WaitSignal>

Returns a flux of wait signals as processing progresses.

waitingLast

open override fun waitingLast(): Mono<WaitSignal>

Returns a mono that completes with the final wait signal.