diff --git a/lib/WebSocketTransport.js b/lib/WebSocketTransport.js index aba60bab6c9..492beb62661 100644 --- a/lib/WebSocketTransport.js +++ b/lib/WebSocketTransport.js @@ -25,9 +25,9 @@ class WebSocketTransport { */ static create(url) { return new Promise((resolve, reject) => { - const ws = new WebSocket(url, { perMessageDeflate: false }); - ws.on('open', () => resolve(new WebSocketTransport(ws))); - ws.on('error', reject); + const ws = new WebSocket(url, [], { perMessageDeflate: false }); + ws.addEventListener('open', () => resolve(new WebSocketTransport(ws))); + ws.addEventListener('error', reject); }); } @@ -36,16 +36,16 @@ class WebSocketTransport { */ constructor(ws) { this._ws = ws; - this._ws.on('message', event => { + this._ws.addEventListener('message', event => { if (this.onmessage) - this.onmessage.call(null, event); + this.onmessage.call(null, event.data); }); - this._ws.on('close', event => { + this._ws.addEventListener('close', event => { if (this.onclose) this.onclose.call(null); }); // Silently ignore all errors - we don't know what to do with them. - this._ws.on('error', () => {}); + this._ws.addEventListener('error', () => {}); this.onmessage = null; this.onclose = null; }