InMemoryCommandBus
constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<CommandMessage<*>> = {
mpscUnicastManySink()
})
Parameters
sinkSupplier
Function that creates a unicast sink for each named aggregate. Defaults to an atomic MPSC unicast sink with backpressure buffer.