retry-request+8.0.2.patch 959 B

12345678910111213141516171819202122
  1. diff --git a/node_modules/retry-request/index.js b/node_modules/retry-request/index.js
  2. index 298a351..7ec1ef8 100644
  3. --- a/node_modules/retry-request/index.js
  4. +++ b/node_modules/retry-request/index.js
  5. @@ -185,7 +185,7 @@ function retryRequest(requestOpts, opts, callback) {
  6. .on('complete', (...params) => handleFinish(params))
  7. .on('finish', (...params) => handleFinish(params));
  8. - requestStream.pipe(delayStream);
  9. + pipeline(requestStream, delayStream, () => {});
  10. } else {
  11. activeRequest = opts.request(requestOpts, onResponse);
  12. }
  13. @@ -251,7 +251,7 @@ function retryRequest(requestOpts, opts, callback) {
  14. // No more attempts need to be made, just continue on.
  15. if (streamMode) {
  16. retryStream.emit('response', response);
  17. - delayStream.pipe(retryStream);
  18. + pipeline(delayStream, retryStream, () => {});
  19. requestStream.on('error', err => {
  20. retryStream.destroy(err);
  21. });