import { Subject } from 'rxjs';

class DefaultMessageBus {
  private messagesSubject = new Subject<string>();

  readonly messages$ = this.messagesSubject.asObservable();

  sendMessage(message: string) {
    this.messagesSubject.next(message);
  }
}