diff --git a/lib/node-http-proxy/http-proxy.js b/lib/node-http-proxy/http-proxy.js index cdc5b667e..ffc2c9d4a 100644 --- a/lib/node-http-proxy/http-proxy.js +++ b/lib/node-http-proxy/http-proxy.js @@ -472,8 +472,6 @@ HttpProxy.prototype.proxyWebSocketRequest = function (req, socket, head, buffer) // the appropriate events. // function onUpgrade (reverseProxy, proxySocket) { - var detached; - if (!reverseProxy) { proxySocket.end(); socket.end(); @@ -545,15 +543,12 @@ HttpProxy.prototype.proxyWebSocketRequest = function (req, socket, head, buffer) // from `reverseProxy` and `proxySocket`. // function detach() { - if (!detached) { - detached = true; - proxySocket.destroySoon(); - proxySocket.removeListener('end', listeners.onIncomingClose); - proxySocket.removeListener('data', listeners.onIncoming); - reverseProxy.incoming.socket.destroySoon(); - reverseProxy.incoming.socket.removeListener('end', listeners.onOutgoingClose); - reverseProxy.incoming.socket.removeListener('data', listeners.onOutgoing); - } + proxySocket.destroySoon(); + proxySocket.removeListener('end', listeners.onIncomingClose); + proxySocket.removeListener('data', listeners.onIncoming); + reverseProxy.incoming.socket.destroySoon(); + reverseProxy.incoming.socket.removeListener('end', listeners.onOutgoingClose); + reverseProxy.incoming.socket.removeListener('data', listeners.onOutgoing); } //