sinkSupplier

open override val sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>>

Supplier for creating sinks for command distribution. Uses atomic MPSC admission and unicast mode to support concurrent senders while ensuring each command reaches exactly one consumer.

See also

Sinks.UnicastSpec