TracingWaitStrategy

Constructors

constructor(delegate: WaitStrategy, commandMessage: CommandMessage<*>)

open override val cancelled: Boolean

open override val completed: Boolean

open override val terminated: Boolean

open override val waitCommandId: String

open override fun complete()

open override fun error(throwable: Throwable)

open override fun next(signal: WaitSignal)

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>