| 123456789101112131415161718192021222324252627282930 |
- diff --git a/node_modules/retry-request/index.js b/node_modules/retry-request/index.js
- index 6cd6f65..39efb89 100644
- --- a/node_modules/retry-request/index.js
- +++ b/node_modules/retry-request/index.js
- @@ -1,6 +1,6 @@
- 'use strict';
-
- -var { PassThrough } = require('stream');
- +var { PassThrough, pipeline } = require('stream');
- var debug = require('debug')('retry-request');
- var extend = require('extend');
-
- @@ -164,7 +164,7 @@ function retryRequest(requestOpts, opts, callback) {
- })
- .on('complete', retryStream.emit.bind(retryStream, 'complete'));
-
- - requestStream.pipe(delayStream);
- + pipeline(requestStream, delayStream, () => {});
- } else {
- activeRequest = opts.request(requestOpts, onResponse);
- }
- @@ -220,7 +220,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', function (err) {
- retryStream.destroy(err);
- });
|