import { DomainEvent } from '../../../domain/DomainEvent' ; import { DomainEventSubscriber } from '../../../domain/DomainEventSubscriber' ; import { EventBus } from '../../../domain/EventBus' ; import { DomainEventMapping } from '../DomainEventMapping' ; import { EventEmitterBus } from '../EventEmitterBus' ; export class InMemoryAsyncEventBus implements EventBus { private bus : EventEmitterBus ; constructor ( subscribers ) { this . bus = new EventEmitterBus ( subscribers ) ; } async start ( ) { } async publish ( events ) { this . bus . publish ( events ) ; } addSubscribers ( subscribers ) { this . bus . registerSubscribers ( subscribers ) ; } setDomainEventMapping ( domainEventMapping ) { } }