From 37b16a900740a070cb29a77109cb8cd23e82f24d Mon Sep 17 00:00:00 2001
From: Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com>
Date: Sun, 11 Dec 2022 13:01:41 -0800
Subject: Add _read

---
 src/bun.js/builtins/js/ProcessObjectInternals.js | 19 +++++++++++++++++--
 1 file changed, 17 insertions(+), 2 deletions(-)

(limited to 'src/bun.js/builtins/js')

diff --git a/src/bun.js/builtins/js/ProcessObjectInternals.js b/src/bun.js/builtins/js/ProcessObjectInternals.js
index be23220b1..bcbc7873e 100644
--- a/src/bun.js/builtins/js/ProcessObjectInternals.js
+++ b/src/bun.js/builtins/js/ProcessObjectInternals.js
@@ -511,10 +511,21 @@ function getStdinStream(fd, rawRequire, Bun) {
     }
 
     on(ev, cb) {
+      super.on(ev, cb);
       if (!this.#readStream && (ev === "readable" || ev === "data")) {
         this.#loadReadStream();
       }
-      return super.on(ev, cb);
+
+      return this;
+    }
+
+    once(ev, cb) {
+      super.once(ev, cb);
+      if (!this.#readStream && (ev === "readable" || ev === "data")) {
+        this.#loadReadStream();
+      }
+
+      return this;
     }
 
     #loadReadStream() {
@@ -547,7 +558,11 @@ function getStdinStream(fd, rawRequire, Bun) {
       this.#readStream?.unref?.();
     }
 
-    _read(encoding, callback) {}
+    _read(encoding, callback) {
+      if (!this.#readStream) this.#loadReadStream();
+
+      return this.#readStream._read(...arguments);
+    }
 
     #constructWriteStream() {
       var { createWriteStream } = require("node:fs");
-- 
cgit v1.2.3