[feature] add buffer support

http-party · Oct 26, 2013 · e3f8d5f · e3f8d5f
1 parent a1b25a1
commit e3f8d5f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/lib/http-proxy/passes/web-incoming.js b/lib/http-proxy/passes/web-incoming.js
@@ -106,6 +106,7 @@ web_o = Object.keys(web_o).map(function(pass) {
 
     // Error Handler
     proxyReq.on('error', function(err){
+      if(options.buffer) { options.buffer.destroy(); }
       if (clb) {
         clb(err);
       } else {
@@ -123,6 +124,10 @@ web_o = Object.keys(web_o).map(function(pass) {
       proxyRes.pipe(res);
     });
 
+    if(options.buffer) {
+      options.buffer.resume();
+    }
+
     //proxyReq.end();
   }