diff --git a/server/lib/transports/WebSocketTransport.js b/server/lib/transports/WebSocketTransport.js index 510e3bc..da3c391 100644 --- a/server/lib/transports/WebSocketTransport.js +++ b/server/lib/transports/WebSocketTransport.js @@ -70,7 +70,17 @@ class WebSocketTransport extends EnhancedEventEmitter try { - this._connection.sendUTF(JSON.stringify(message)); + return new Promise((resolve, reject) => { + this._connection.sendUTF(JSON.stringify(message), (error) => { + if(error) { + logger.warn('send() failed:%o', error); + + reject(error); + } else { + resolve() + } + }); + }); } catch (error) {