memory leak fix in closing of the scokets

lib/node-http-proxy/http-proxy.js

@@ -551,24 +551,31 @@ HttpProxy.prototype.proxyWebSocketRequest = function (req, socket, head, buffer)
       reverseProxy.incoming.socket.removeListener('data', listeners.onOutgoing);
     }
 
-    //
+   //
     // If the incoming `proxySocket` socket closes, then
     // detach all event listeners.
     //
-    proxySocket.on('end', listeners.onIncomingClose = function() {
+    listeners.onIncomingClose = function() {
+      reverseProxy.incoming.socket.destroy();
       detach();
 
       // Emit the `end` event now that we have completed proxying
-      self.emit('websocket:end', req, socket, head);
-    });
+      self.emit('websocket:end', req, socket, head);    
+    }
 
     //
     // If the `reverseProxy` socket closes, then detach all
     // event listeners.
-    //
-    reverseProxy.incoming.socket.on('end', listeners.onOutgoingClose = function() {
-      detach();
-    });
+    //    
+    listeners.onOutgoingClose = function() {
+      proxySocket.destroy();
+      detach();   
+    }
+
+    proxySocket.on('end', listeners.onIncomingClose);
+    proxySocket.on('close', listeners.onIncomingClose);
+    reverseProxy.incoming.socket.on('end', listeners.onOutgoingClose);
+    reverseProxy.incoming.socket.on('close', listeners.onOutgoingClose);
   }
 
   function getPort (port) {