diff --git a/node_modules/@google-cloud/storage/node_modules/retry-request/index.js b/node_modules/@google-cloud/storage/node_modules/retry-request/index.js
index 2fae107..32ec707 100644
--- a/node_modules/@google-cloud/storage/node_modules/retry-request/index.js
+++ b/node_modules/@google-cloud/storage/node_modules/retry-request/index.js
@@ -1,6 +1,6 @@
 'use strict';
 
-const {PassThrough} = require('stream');
+const {PassThrough, pipeline} = require('stream');
 const extend = require('extend');
 
 let debug = () => {};
@@ -185,7 +185,7 @@ function retryRequest(requestOpts, opts, callback) {
         .on('complete', (...params) => handleFinish(params))
         .on('finish', (...params) => handleFinish(params));
 
-      requestStream.pipe(delayStream);
+      pipeline(requestStream, delayStream, () => {});
     } else {
       activeRequest = opts.request(requestOpts, onResponse);
     }
@@ -251,7 +251,7 @@ function retryRequest(requestOpts, opts, callback) {
     // No more attempts need to be made, just continue on.
     if (streamMode) {
       retryStream.emit('response', response);
-      delayStream.pipe(retryStream);
+      pipeline(delayStream, retryStream, () => {});
       requestStream.on('error', err => {
         retryStream.destroy(err);
       });