import { Component, Input, Output, EventEmitter } from '@angular/core'; import { of } from 'rxjs'; import { map, catchError, take } from 'rxjs/operators'; import { Host } from '@overflow/model/discovery'; import { PingResult } from '@overflow/model/ping'; import { ProbeService } from '../service/probe.service'; @Component({ selector: 'app-host-detail', templateUrl: './host-detail.component.html', styleUrls: ['./host-detail.component.scss'], }) export class HostDetailComponent { @Input() host: Host; pingWaiting: boolean; retries: number; interval: number; deadline: number; pingResult: PingResult; constructor( private probeService: ProbeService, ) { this.pingWaiting = false; this.retries = 5; this.interval = 1; this.deadline = 1; } doPing() { this.pingWaiting = true; const option = { Retry: this.retries, Interval: this.interval, Deadline: this.deadline, }; this.probeService .call('PingService.PingHost', this.host, option) .pipe( map((pingResult: PingResult) => { if (pingResult) { this.pingResult = pingResult; } this.pingWaiting = false; }), catchError(error => { console.log(error); alert('An error has occurred.'); this.pingWaiting = false; return of(); }), take(1) ) .subscribe(); } }