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