import { Injectable } from '@angular/core';
import { Subject ,  Subscription ,  Observable } from 'rxjs';
import { CommunicationSubject } from '../interfaces/communication.subject';



@Injectable()
export class HBORCommunicationService {
  public refresh = new Subject<boolean>();
  public delete = new Subject<CommunicationSubject>();
  public rowLimit = new Subject<number>();
  public rowLimitRaw = 15;
  public errorOccured = new Subject<boolean>();

  // Observable boolean streams
  public refresh$ = this.refresh.asObservable();
  public delete$ = this.delete.asObservable();
  public rowLimit$ = this.rowLimit.asObservable();
  public errorOccured$ = this.errorOccured.asObservable();

  // Service message commands
  publishDataRefresh(state: boolean) {
    this.refresh.next(state);
  }

  publishDataDelete(state: CommunicationSubject) {
    this.delete.next(state);
  }

  publishDataRowLimit(state: number) {
    this.rowLimit.next(state);
    this.rowLimitRaw = state;
  }

  publishErrrorOccured(state: true) {
    this.errorOccured.next(state);
  }
}