diff --git a/lib/stream.js b/lib/stream.js index f8d410e..31bbec3 100644 --- a/lib/stream.js +++ b/lib/stream.js @@ -58,8 +58,8 @@ function createWebSocketStream(ws, options) { ws._receiver.on('drain', receiverOnDrain); }); } else { - ws._receiver.removeAllListeners('drain'); - ws._receiver.on('drain', receiverOnDrain); + if (ws && ws._receiver) ws._receiver.removeAllListeners('drain'); + if (ws && ws._receiver) ws._receiver.on('drain', receiverOnDrain); } const duplex = new Duplex({ diff --git a/package.json b/package.json index ce6a046..665f788 100644 --- a/package.json +++ b/package.json @@ -1,6 +1,6 @@ { "name": "wspp", - "version": "7.2.8", + "version": "7.2.9", "description": "fork of wspp for work with node-httpp", "keywords": [ "HyBi",