Workaround for #9041

src/js/node/stream.js

@@ -3388,9 +3388,21 @@ var require_readable = __commonJS({
     };
 
     Readable.fromWeb = function (readableStream, options) {
+      // We cache .stream() calls for file descriptors
+      // This won't create a new ReadableStream each time.
+      let bunStdinStream = Bun.stdin.stream();
+      if (readableStream === bunStdinStream) {
+        return bunStdinStream;
+      }
+
       return webStreamsAdapters.newStreamReadableFromReadableStream(readableStream, options);
     };
     Readable.toWeb = function (streamReadable, options) {
+      // Workaround for https://github.com/oven-sh/bun/issues/9041
+      if (streamReadable === process.stdin) {
+        return Bun.stdin.stream();
+      }
+
       return webStreamsAdapters.newReadableStreamFromStreamReadable(streamReadable, options);
     };
     Readable.wrap = function (src, options) {

test/regression/issue/09041.test.ts

@@ -0,0 +1,26 @@
+import { test, expect } from "bun:test";
+import { bunEnv, bunExe, tempDirWithFiles } from "harness";
+import { join } from "path";
+import { $ } from "bun";
+import { cp, rm } from "fs/promises";
+test("09041", async () => {
+  const out = tempDirWithFiles("09041", {
+    "09041-fixture.mjs": await Bun.file(join(import.meta.dir, "09041", "09041-fixture.mjs")).text(),
+    "09041-fixture.test.js": await Bun.file(join(import.meta.dir, "09041", "09041-fixture-test.txt")).text(),
+    "package.json": `{}`,
+  });
+
+  let { exited, stderr, stdout } = Bun.spawn({
+    cmd: [bunExe(), "test"],
+    cwd: out,
+    env: bunEnv,
+    stdio: ["ignore", "pipe", "inherit"],
+  });
+
+  expect(await exited).toBe(0);
+  const err = await new Response(stderr).text();
+  expect(err).toContain("1 pass");
+  expect(err).toContain("0 fail");
+
+  await rm(out, { force: true, recursive: true });
+}, 10000);