From a6ec7fe9b17bc270108eb12d8b97aa4a02bfbe09 Mon Sep 17 00:00:00 2001 From: Dylan Conway Date: Thu, 10 Aug 2023 19:06:51 -0700 Subject: don't check for trailing slash, var stream --- src/js/builtins/ProcessObjectInternals.ts | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) (limited to 'src/js/builtins/ProcessObjectInternals.ts') 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 { -- cgit v1.2.3