InMemoryEventQueryStorage

constructor(streams: suspend (AggregateType) -> List<EventStreamRecord>, delay: Duration = Duration.ZERO)