import { Injectable } from '@angular/core';

import {
    Subject,
    Observable
} from 'rxjs';

import { BroadcastMessage } from './broadcast.payload';
import { IBroadcastService } from './broadcast.interface';

@Injectable()
export class BroadcastService implements IBroadcastService {
    private message: Subject<BroadcastMessage<any>>;

    constructor() {
        this.initialize();
    }

    private initialize(): void {
        this.message = new Subject<BroadcastMessage<any>>();
    }

    public publishMessage<T>(message: BroadcastMessage<T>): void {
        this.message.next(message);
    }

    public receiveMessage<T>(): Observable<BroadcastMessage<T>> {
        return this.message.asObservable();
    }
}