aboutsummaryrefslogtreecommitdiff
path: root/src/js/builtins/ProcessObjectInternals.ts
diff options
context:
space:
mode:
authorGravatar Dylan Conway <dylan.conway567@gmail.com> 2023-08-10 19:06:51 -0700
committerGravatar Dylan Conway <dylan.conway567@gmail.com> 2023-08-10 19:06:51 -0700
commita6ec7fe9b17bc270108eb12d8b97aa4a02bfbe09 (patch)
treed88077a39e4b5b2f0c4463def5fc0db979b82795 /src/js/builtins/ProcessObjectInternals.ts
parent513a6d0df3d4d991e76f8e7762df7a07a8087a81 (diff)
downloadbun-a6ec7fe9b17bc270108eb12d8b97aa4a02bfbe09.tar.gz
bun-a6ec7fe9b17bc270108eb12d8b97aa4a02bfbe09.tar.zst
bun-a6ec7fe9b17bc270108eb12d8b97aa4a02bfbe09.zip
don't check for trailing slash, var stream
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 {