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

WaitStrategy

interface WaitStrategy : WaitCommandIdCapable, WaitStrategyPropagator, CompletedCapable

Command Wait Strategy

Inheritors

Types

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

Materialized

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

Properties

cancelled

abstract val cancelled: Boolean

completed

open override val completed: Boolean

materialized

abstract val materialized: WaitStrategy.Materialized

supportVoidCommand

abstract val supportVoidCommand: Boolean

Whether this strategy supports void commands.

terminated

abstract 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

abstract fun complete()

Marks the wait strategy as completed.

error

abstract fun error(throwable: Throwable)

Signals an error occurred during command processing.

abstract fun next(signal: WaitSignal)

Receives the next processing result signal from downstream processors.

onFinally

abstract 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

abstract fun waiting(): Flux<WaitSignal>

Returns a flux of wait signals as processing progresses.

waitingLast

abstract fun waitingLast(): Mono<WaitSignal>

Returns a mono that completes with the final wait signal.

WaitStrategy

See also

Inheritors

Types

Properties

Functions