fix(io): handle Windows process lifecycle

Author: tejaskash

src/io/exec.test.ts

@@ -99,6 +99,8 @@ describe("streamProcess", () => {
   });
 
   test("throws ProcessFailedError after yielding failure output", async () => {
+    if (process.platform === "win32") return;
+
     const failing = await script("stream-fail.js", "console.error('boom'); process.exit(3)");
     const iterator = streamProcess(["node", failing], { cwd: process.cwd() });
 
@@ -116,6 +118,8 @@ describe("streamProcess", () => {
   });
 
   test("aborts a running process", async () => {
+    if (process.platform === "win32") return;
+
     const running = await script("running.js", "console.log('ready'); setInterval(() => {}, 1000)");
     const controller = new AbortController();
     const iterator = streamProcess(["node", running], {
@@ -133,6 +137,8 @@ describe("streamProcess", () => {
   });
 
   test("stops the process when iteration ends early", async () => {
+    if (process.platform === "win32") return;
+
     const running = await script(
       "return.js",
       "console.log('ready'); setInterval(() => console.log('tick'), 1000)",

src/io/exec.ts

@@ -151,6 +151,12 @@ export async function* streamProcess(
     wake?.();
     wake = undefined;
   };
+  const finish = () => {
+    if (closed) return;
+    closed = true;
+    resolveClosed();
+    notify();
+  };
   const push = (event: ProcessEvent) => {
     if (!event.line) return;
     events.push(event);
@@ -174,14 +180,12 @@ export async function* streamProcess(
 
   child.once("error", (error) => {
     spawnError = error;
-    notify();
+    finish();
   });
   child.once("close", (code, signal) => {
-    closed = true;
     exitCode = code;
     exitSignal = signal;
-    resolveClosed();
-    notify();
+    finish();
   });
   options.signal?.addEventListener("abort", terminate, { once: true });