aboutsummaryrefslogtreecommitdiff
path: root/src/js/builtins/ProcessObjectInternals.ts
diff options
context:
space:
mode:
Diffstat (limited to 'src/js/builtins/ProcessObjectInternals.ts')
-rw-r--r--src/js/builtins/ProcessObjectInternals.ts11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/js/builtins/ProcessObjectInternals.ts b/src/js/builtins/ProcessObjectInternals.ts
index af51d25cd..242b310fd 100644
--- a/src/js/builtins/ProcessObjectInternals.ts
+++ b/src/js/builtins/ProcessObjectInternals.ts
@@ -128,9 +128,9 @@ export function getStdioWriteStream(fd_, getWindowSize) {
_write(chunk, encoding, callback) {
if (!this.#writeStream) {
var { createWriteStream } = require("node:fs");
- this.#writeStream = createWriteStream(this.#fdPath);
+ var stream = (this.#writeStream = createWriteStream(this.#fdPath));
- this.#writeStream.on("finish", () => {
+ stream.on("finish", () => {
if (this.#onFinish) {
const cb = this.#onFinish;
this.#onFinish = null;
@@ -138,7 +138,7 @@ export function getStdioWriteStream(fd_, getWindowSize) {
}
});
- this.#writeStream.on("drain", () => {
+ stream.on("drain", () => {
if (this.#onDrain) {
const cb = this.#onDrain;
this.#onDrain = null;
@@ -146,14 +146,15 @@ export function getStdioWriteStream(fd_, getWindowSize) {
}
});
- eos(this.#writeStream, err => {
+ eos(stream, err => {
this.#writable = false;
if (err) {
- destroy(this.#writeStream, err);
+ destroy(stream, err);
}
this.#onFinished(err);
});
}
+
if (this.#writeStream.write(chunk, encoding)) {
callback();
} else {