aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-15 21:37:28 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-15 21:37:28 -0800
commitc32013dbbaa9d9cdca1c97b4bae1f894584c7f4e (patch)
treec9e7d3288a424c9066182621db216b3f593efd7d
parent6cdb7e77dda5d1affe8a1b033e6d35ab1e78234d (diff)
downloadbun-c32013dbbaa9d9cdca1c97b4bae1f894584c7f4e.tar.gz
bun-c32013dbbaa9d9cdca1c97b4bae1f894584c7f4e.tar.zst
bun-c32013dbbaa9d9cdca1c97b4bae1f894584c7f4e.zip
Never resize on close
-rw-r--r--src/bun.js/streams.exports.js8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/bun.js/streams.exports.js b/src/bun.js/streams.exports.js
index 4e812437e..7e52312ad 100644
--- a/src/bun.js/streams.exports.js
+++ b/src/bun.js/streams.exports.js
@@ -5786,7 +5786,7 @@ function createNativeStream(nativeType, Readable) {
#handleResult(result, view, isClosed) {
if (typeof result === "number") {
- if (result >= this.#highWaterMark && !this.#hasResized) {
+ if (result >= this.#highWaterMark && !this.#hasResized && !isClosed) {
this.#highWaterMark *= 2;
this.#hasResized = true;
}
@@ -5796,7 +5796,11 @@ function createNativeStream(nativeType, Readable) {
this.push(null);
return view?.byteLength ?? 0 > 0 ? view : undefined;
} else if (ArrayBuffer.isView(result)) {
- if (result.byteLength >= this.#highWaterMark && !this.#hasResized) {
+ if (
+ result.byteLength >= this.#highWaterMark &&
+ !this.#hasResized &&
+ !isClosed
+ ) {
this.#highWaterMark *= 2;
this.#hasResized = true;
}