diff --git a/stream.js b/stream.js index 0f6254a..886e395 100644 --- a/stream.js +++ b/stream.js @@ -83,6 +83,8 @@ function WebSocketStream(target, protocols, options) { socket.onerror = onerror socket.onmessage = onmessage + proxy.on('error', function(){}) + proxy.on('close', destroy) var coerceToBuffer = !options.objectMode