Шина сообщений angular 6

в настоящее время наша команда разработала простое приложение angular 6 с несколькими компонентами, и они работают правильно, но мы знаем, что эти компоненты уже слишком связаны друг с другом (они слишком много знают о себе). Поэтому, естественно, мы хотим перейти к решению развязки, такому как популярная шина событий/сообщений внутри приложения angular 6.

Таким образом, компоненты вместо того, чтобы подписываться друг на друга, должны знать только о шине сообщений и заботиться только о том, что публикуется в шине и подписывается на нее.

Этот пример реализации основан на классе Подписка, но, согласно Интернету, лучшим решением было бы использовать ПоведениеТема.

Итак, у меня есть несколько вопросов:

1. стоит ли менять Subscription -> BehaviorSubject?

   2. Лучше ли сейчас иметь список подписок вместо одной?
   3. Как установить начальное значение для подписки при подписке?
   4. Если я хочу избавиться от канала и хотел бы использовать что-то еще, например пространство имен класса сообщений, то как его можно получить? Это хороший подход?

   импортировать {Injectable} из '@angular/core'; импортировать {Observable, Subject} из 'rxjs/Rx'; импортировать {filter, map} из 'rxjs/operators';

   интерфейс экспорта IClassConstructor { новый (...аргументы: любой[]): T; }

   интерфейс экспорта IMessage { канал: функция; содержание: любое; } /** простая шина сообщений публикации/подписки на основе классов для обеспечения несвязанной связи событий, действий и команд */ @Инъекционный() экспортировать класс MessageService { личное сообщение = новая тема();

   public publish<T>(messageInstance: T): void {   // Flux/Redux: 'dispatch'
       const channel = messageInstance.constructor;
       this.message.next({'channel': channel, 'content': messageInstance}); // Redux: {'type': string, 'payload': any }
   }
   
   public subscribe<T>(messageClass: IClassConstructor<T>): Observable<T> {
       const channel: IClassConstructor<T> = messageClass;
       return this.message.pipe(
           filter((message: IMessage) => {
               return message.channel === channel;
           }),
           map((message: IMessage) => {
               return message.content;
           })
       );
   }
   

   }