readable.js

readable.js

diff --git a/lib/internal/streams/readable.js b/lib/internal/streams/readable.js
index 93153908fe..366a2a5ad6 100644
--- a/lib/internal/streams/readable.js
+++ b/lib/internal/streams/readable.js
@@ -787,6 +787,11 @@ Readable.prototype.pipe = function(dest, pipeOpts) {
   if (dest.writableNeedDrain === true) {
     if (state.flowing) {
       src.pause();
+
+      // Resume src when we can
+      dest.once('drain', function() {
+        src.resume();
+      });
     }
   } else if (!state.flowing) {
     debug('pipe resume');