| 12345678910111213141516171819202122 |
- diff --git a/node_modules/retry-request/index.js b/node_modules/retry-request/index.js
- index 298a351..7ec1ef8 100644
- --- a/node_modules/retry-request/index.js
- +++ b/node_modules/retry-request/index.js
- @@ -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);
- });
|