| 123456789101112131415161718192021222324252627282930 |
- diff --git a/node_modules/@google-cloud/logging/node_modules/retry-request/index.js b/node_modules/@google-cloud/logging/node_modules/retry-request/index.js
- index 2fae107..5721c54 100644
- --- a/node_modules/@google-cloud/logging/node_modules/retry-request/index.js
- +++ b/node_modules/@google-cloud/logging/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);
- });
|