diff --git a/lib/http-proxy/passes/ws-incoming.js b/lib/http-proxy/passes/ws-incoming.js
index 270f23f45..9e3d80d5e 100644
--- a/lib/http-proxy/passes/ws-incoming.js
+++ b/lib/http-proxy/passes/ws-incoming.js
@@ -113,7 +113,7 @@ module.exports = {
       // if upgrade event isn't going to happen, close the socket
       if (!res.upgrade) {
         socket.write(createHttpHeader('HTTP/' + res.httpVersion + ' ' + res.statusCode + ' ' + res.statusMessage, res.headers));
-        res.pipe(socket);
+        res.pipe(socket).on('error', onOutgoingError);
       }
     });