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