import {Injectable} from '@angular/core';
  import {BehaviorSubject, Observable} from 'rxjs';

  import {Message} from '../model/message';

  
  @Injectable({
    providedIn: 'root'
  })
  export class VesselsService {
    private vessels = new BehaviorSubject(new Map());
    currentVessels = this.vessels.asObservable();
  
    constructor() {
    }

    changeVesselsSet(newVessels: Map<number, Message>): void {

      this.vessels.next(newVessels);
    }
  }