InMemoryDomainEventBus

constructor(sinkSupplier: (NamedAggregate) -> Sinks.Many<DomainEventStream> = { Sinks.many().multicast().onBackpressureBuffer() })