sendAndWaitStream
open override fun <C : Any> sendAndWaitStream(command: CommandMessage<C>, waitStrategy: WaitStrategy): Flux<CommandResult>
Sends a command and returns a stream of command results as they become available. This method allows monitoring the progress of command execution in real-time.
Return
A Flux emitting CommandResult instances as they are produced.
Parameters
C
The type of the command body.
command
The command message to send.
waitStrategy
The strategy defining how and what to wait for.
Throws
if the command is not idempotent.
ConstraintViolationException
if validation fails.
if the wait strategy doesn't support void commands when needed.