InMemoryDomainEventBus
constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = {
Sinks.many().multicast().onBackpressureBuffer()
})
Creates a new InMemoryDomainEventBus with the specified sink supplier
Parameters
sinkSupplier
The function to create sinks for named aggregates