diff --git a/lib/internal/streams/pipeline.js b/lib/internal/streams/pipeline.js index 798745a110d51b..07ecaea9794d50 100644 --- a/lib/internal/streams/pipeline.js +++ b/lib/internal/streams/pipeline.js @@ -50,7 +50,16 @@ function call(fn) { } function pipe(from, to) { - return from.pipe(to); + from.pipe(to); + + if (isRequest(to)) { + to.on('response', function() { + from.unpipe(this); + from.resume(); + }); + } + + return to; } function popCallback(streams) {