Revert "fix: destroy piped streams on child exit to prevent grandchild deadlock (tinylibs#137)"

This reverts commit 20e4117.

Author: iiroj

src/main.ts

@@ -17,8 +17,6 @@ export {NonZeroExitError, normalizeSpawnCommand};
 
 const LINE_SEPARATOR_REGEX = /\r?\n/;
 
-const pipedStreams = new WeakSet<Readable>();
-
 export interface Output {
   stderr: string;
   stdout: string;
@@ -336,7 +334,6 @@ export class ExecProcess implements Result {
 
     this._process = handle;
     handle.once('error', this._onError);
-    handle.once('exit', this._onExit);
     handle.once('close', this._onClose);
 
     if (handle.stdin) {
@@ -345,11 +342,7 @@ export class ExecProcess implements Result {
       if (typeof stdin === 'string') {
         handle.stdin.end(stdin);
       } else {
-        const src = stdin?.process?.stdout;
-        if (src) {
-          src.pipe(handle.stdin);
-          pipedStreams.add(src);
-        }
+        stdin?.process?.stdout?.pipe(handle.stdin);
       }
     }
   }
@@ -373,28 +366,6 @@ export class ExecProcess implements Result {
     this._thrownError = err;
   };
 
-  protected _onExit = (): void => {
-    // Node emits 'exit' before stdio streams have drained. Use setImmediate
-    // to let buffered data flow through before destroying the streams.
-    // If grandchild processes hold the pipe fds open, they would never fire
-    // 'close', so we destroy here to unblock readStream and combineStreams.
-    const out =
-      this._streamOut && !pipedStreams.has(this._streamOut)
-        ? this._streamOut
-        : undefined;
-    const err =
-      this._streamErr && !pipedStreams.has(this._streamErr)
-        ? this._streamErr
-        : undefined;
-    if (!out && !err) {
-      return;
-    }
-    setImmediate(() => {
-      out?.destroy();
-      err?.destroy();
-    });
-  };
-
   protected _onClose = (): void => {
     if (this._resolveClose) {
       this._resolveClose();