fix: use pipeline in place of pipe to better handle cleanup / errors (#…

…299)
googleapis · Feb 17, 2023 · 31d9002 · 31d9002
1 parent fdecde6
commit 31d9002
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/index.ts b/src/index.ts
@@ -18,7 +18,7 @@
 import {Agent, AgentOptions as HttpsAgentOptions} from 'https';
 import {AgentOptions as HttpAgentOptions} from 'http';
 import fetch, * as f from 'node-fetch';
-import {PassThrough, Readable} from 'stream';
+import {PassThrough, Readable, pipeline} from 'stream';
 import * as uuid from 'uuid';
 import {getAgent} from './agents';
 import {TeenyStatistics} from './TeenyStatistics';
@@ -263,10 +263,10 @@ function teenyRequest(
     let responseStream: any;
     requestStream.once('reading', () => {
       if (responseStream) {
-        responseStream.pipe(requestStream);
+        pipeline(responseStream, requestStream, () => {});
       } else {
         requestStream.once('response', () => {
-          responseStream.pipe(requestStream);
+          pipeline(responseStream, requestStream, () => {});
         });
       }
     });