sendAndWaitStream
open override fun <C : Any> sendAndWaitStream(command: CommandMessage<C>, waitPlan: WaitPlan): 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
command
The command message to send.
waitPlan
The plan defining how and what to wait for.
Type Parameters
C
The type of the command body.
Throws
if the command is not idempotent.
jakarta.validation.ConstraintViolationException
if validation fails.
if the wait plan doesn't support void commands when needed.