From 3b7c8daafe2f458d8374767d704bb38532548e0e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Krist=C3=B3f=20T=C3=B3th?= Date: Wed, 14 Mar 2018 17:06:56 +0100 Subject: [PATCH] Add optional trigger argument to WebSocketService --- src/app/services/websocket.service.ts | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) diff --git a/src/app/services/websocket.service.ts b/src/app/services/websocket.service.ts index cadba56..6f7495d 100644 --- a/src/app/services/websocket.service.ts +++ b/src/app/services/websocket.service.ts @@ -43,14 +43,19 @@ export class WebSocketService { return this.downlink.pipe(filter(message => message.key === key)); } - public send(key: string, data: any): void { + public send(key: string, data?: any, trigger?: any): void { // If the WebSocket is not connected then the QueueingSubject will ensure // that messages are queued and delivered when the WebSocket reconnects. // A regular Subject can be used to discard messages sent when the WebSocket // is disconnected. - this.uplink.next({ - 'key': key, - 'data': data - }); + // TODO: do this nicer? + const message = {'key': key}; + if (data) { + message['data'] = data; + } + if (trigger) { + message['trigger'] = trigger; + } + this.uplink.next(message); } }