import { Injectable } from '@angular/core';
import { Subject, Observable } from 'rxjs';
import { Message } from '../../../primeng/api';

@Injectable()
export class MessageService {
    
    private messageSource:Subject<Message|Message[]>;
    messageObserver: Observable<Message | Message[]>;
    
    load () {
        this.messageSource = new Subject<Message|Message[]>();
        
        this.messageObserver = this.messageSource.asObservable();

    }
    
    add(message: Message) {
        if(message) {
            this.messageSource.next(message);
        }
    }
    
    addAll(messages: Message[]) {
        if(messages && messages.length) {
            this.messageSource.next(messages);
        } 
    }
    
    clear() {
        this.messageSource.next(null);
    }
}