import { Injectable } from '@angular/core'; import {Subject} from "rxjs"; @Injectable({ providedIn: 'root' }) export class CommunicationService { private messageSource = new Subject(); currentMessage = this.messageSource.asObservable(); constructor() { } sendMessage(message: string) { this.messageSource.next(message); } }