use bunExe and bunEnv

src/js/node/readline.ts

@@ -1583,6 +1583,7 @@ var _Interface = class Interface extends InterfaceConstructor {
       this[kSetRawMode](false);
     }
     this.closed = true;
+    this.input.close?.();
     this.emit("close");
   }
 

test/js/node/readline/fixtures/not-empty.txt

@@ -0,0 +1 @@
+foo

test/js/node/readline/fixtures/readline-empty-file-immediate-close.ts

@@ -0,0 +1,12 @@
+import readline from "readline";
+import fs from "fs";
+import path from "path";
+
+const emptyFile = fs.createReadStream(path.resolve(__dirname, "empty.txt"), "utf8");
+
+const rl1 = readline.createInterface({
+  input: emptyFile,
+  output: process.stdout,
+});
+
+rl1.close();

test/js/node/readline/fixtures/readline-nonempty-file-immediate-close.ts

@@ -0,0 +1,12 @@
+import readline from "readline";
+import fs from "fs";
+import path from "path";
+
+const nonEmptyFile = fs.createReadStream(path.resolve(__dirname, "not-empty.txt"), "utf8");
+
+const rl1 = readline.createInterface({
+  input: nonEmptyFile,
+  output: process.stdout,
+});
+
+rl1.close();

test/js/node/readline/fixtures/readline-stdin-immediate-close.ts

@@ -0,0 +1,8 @@
+import readline from "readline";
+
+const rl1 = readline.createInterface({
+  input: process.stdin,
+  output: process.stdout,
+});
+
+rl1.close();

test/js/node/readline/readline.node.test.ts

@@ -1,8 +1,10 @@
 // @ts-nocheck
+import { bunEnv, bunExe } from "harness";
 import { createTest } from "node-harness";
 import { EventEmitter } from "node:events";
 import readline from "node:readline";
 import { PassThrough, Writable } from "node:stream";
+import path from "path";
 const { beforeEach, describe, it, createDoneDotAll, createCallCheckCtx, assert } = createTest(import.meta.path);
 
 var {
@@ -15,6 +17,8 @@ var {
 // Helpers
 // ----------------------------------------------------------------------------
 
+/** Get an absolute path to a `readline` fixture. */
+const fixture = (name: string): string => path.resolve(import.meta.dirname, "fixtures", name);
 class TestWritable extends Writable {
   data;
   constructor() {
@@ -1327,6 +1331,44 @@ describe("readline.Interface", () => {
     assert.strictEqual(getStringWidth("\u0301\u200D\u200E"), 0);
   });
 
+  const testForEventLoopHangs = (fixtureName: string) => async () => {
+    // race a timeout and the subprocess promise
+    const subprocess = Bun.spawn({
+      cmd: [bunExe(), "run", fixture(fixtureName)],
+      env: bunEnv,
+    });
+
+    const timeoutAfter = 2_500;
+    var _timer: Timer | undefined;
+    const timeout = new Promise((_, reject) => {
+      _timer = setTimeout(() => {
+        _timer = undefined;
+        resolve(); // we're gonna race these
+      }, timeoutAfter);
+    });
+
+    await Promise.race([subprocess.exited, timeout]);
+    if (_timer) clearTimeout(_timer);
+    if (subprocess.exitCode == null) {
+      throw new Error("readline did not close after 2.5s. This means stdint is keeping the event loop alive.");
+    } else if (subprocess.exitCode !== 0) {
+      throw new Error(`subprocess exited with a non-zero code: ${subprocess.exitCode}`);
+    }
+  };
+
+  it(
+    "should not hang when stdin is immediately and synchronously closed",
+    testForEventLoopHangs("readline-stdin-immediate-close.ts"),
+  );
+  it(
+    "should not hang when an empty file is immediately and synchronously closed",
+    testForEventLoopHangs("readline-empty-file-immediate-close.ts"),
+  );
+  it(
+    "should not hang when a non-empty file is immediately and synchronously closed",
+    testForEventLoopHangs("readline-nonempty-file-immediate-close.ts"),
+  );
+
   // // Check if vt control chars are stripped
   // assert.strictEqual(stripVTControlCharacters('\u001b[31m> \u001b[39m'), '> ');
   // assert.strictEqual(