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/ProcessObjectInternals.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
ciro/fix-test-command'>ciro/fix-test-command
| Unnamed repository; edit this file 'description' to name the repository. | |
Jarred Sumner