mrtoth/frontend-tutorial-framework
1
0
Fork 0
mirror of https://github.com/avatao-content/frontend-tutorial-framework synced 2025-01-16 03:01:56 +00:00
Code Issues Releases Wiki Activity

Replace any with actual type in ProcessManagerService

Browse Source
This commit is contained in:
Kristóf Tóth 2018-03-07 17:14:30 +01:00
parent 955ddac7c6
commit e595b0ccc1
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/app/services/processmanager.service.ts
View File

@ -3,6 +3,7 @@ import { Injectable } from '@angular/core';
import { WebSocketService } from './websocket.service'; import { WebSocketService } from './websocket.service';
import { ProcessCommand } from './processcommand'; import { ProcessCommand } from './processcommand';
import { filter } from 'rxjs/operators'; import { filter } from 'rxjs/operators';
import { WSMessage } from './wsmessage';
@Injectable() @Injectable()
@ -16,11 +17,11 @@ export class ProcessManagerService {
this.webSocketService.connect(); this.webSocketService.connect();
} }
subscribeCallback(process_name: string, callback: (event: any) => void) { subscribeCallback(process_name: string, callback: (event: WSMessage<ProcessCommand>) => void) {
this.observeProcessMessage(process_name).subscribe(callback); this.observeProcessMessage(process_name).subscribe(callback);
} }
subscribeErrorCallback(process_name: string, callback: (event: any) => void) { subscribeErrorCallback(process_name: string, callback: (event: WSMessage<ProcessCommand>) => void) {
this.observeProcessMessage(process_name).pipe(filter(message => 'error' in message.data)).subscribe(callback); this.observeProcessMessage(process_name).pipe(filter(message => 'error' in message.data)).subscribe(callback);
} }