WaitingFor

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
abstract val cancelled: Boolean
Link copied to clipboard
abstract val contextName: String
Link copied to clipboard
abstract val processorName: String
Link copied to clipboard
abstract val stage: CommandStage
Link copied to clipboard
abstract val terminated: Boolean

Functions

Link copied to clipboard
abstract fun complete()
Link copied to clipboard
abstract fun error(throwable: Throwable)
Link copied to clipboard
fun NamedBoundedContext.getContextAlias(boundedContext: BoundedContext? = MetadataSearcher.metadata.contexts[contextName]): String
Link copied to clipboard
Link copied to clipboard
abstract fun next(signal: WaitSignal)

由下游(CommandBus or Aggregate or Projector)发送处理结果信号.

Link copied to clipboard
abstract fun onFinally(doFinally: Consumer<SignalType>)
Link copied to clipboard
abstract fun waiting(): Flux<WaitSignal>
Link copied to clipboard
open fun waitingLast(): Mono<WaitSignal>