app

export class AppComponent  {
  name = 'Angular';

  constructor(private _dataService: DataService){
    this._dataService.getControllableDataStream().subscribe(val => {
      console.log("received value: " + val);
    })
  }

  toggleStream(toggle: number) {
    this._dataService.toggleStream(toggle == 1 ? true : false);
    setTimeout(() => {
      console.log("sent value: 1");
      this._dataService.publishToStream(1);

      console.log("sent value: 2");
      this._dataService.publishToStream(2);
    }, 1000)
  }

}