sendAndWaitStream

abstract fun <C : Any> sendAndWaitStream(command: CommandMessage<C>, waitStrategy: WaitStrategy): Flux<CommandResult>

Sends a command and returns a stream of command results as processing progresses.

This method provides real-time updates on the command's processing status, emitting CommandResult objects at various stages of the command lifecycle.

Return

a Flux emitting CommandResult objects as the command progresses

Parameters

C

the type of the command

command

the command message to send

waitStrategy

the strategy defining the processing stages to monitor

See also