InMemoryDomainEventBus
constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = {
Sinks.unsafe().many().multicast().onBackpressureBuffer<DomainEventStream>().concurrent()
})
Creates a new InMemoryDomainEventBus with the specified sink supplier