diff options
Diffstat (limited to 'src/bun.js/builtins/js/ProcessObjectInternals.js')
-rw-r--r-- | src/bun.js/builtins/js/ProcessObjectInternals.js | 19 |
1 files changed, 17 insertions, 2 deletions
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"); |