aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/js
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-10-03 01:07:54 -0700
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-10-03 01:07:54 -0700
commit08d606c3d7ff5accd881b016d51291af54164f06 (patch)
tree379ef953e67832fbc34017abbf5257bdbfd0bfef /src/bun.js/builtins/js
parented82b919a03d9044cb106401030eecf11dc2db81 (diff)
downloadbun-08d606c3d7ff5accd881b016d51291af54164f06.tar.gz
bun-08d606c3d7ff5accd881b016d51291af54164f06.tar.zst
bun-08d606c3d7ff5accd881b016d51291af54164f06.zip
Fix undefined is not a function error in WritableStream
Diffstat (limited to 'src/bun.js/builtins/js')
-rw-r--r--src/bun.js/builtins/js/StreamInternals.js2
-rw-r--r--src/bun.js/builtins/js/WritableStreamInternals.js6
2 files changed, 5 insertions, 3 deletions
diff --git a/src/bun.js/builtins/js/StreamInternals.js b/src/bun.js/builtins/js/StreamInternals.js
index 9f8cb84f4..5e8e4a119 100644
--- a/src/bun.js/builtins/js/StreamInternals.js
+++ b/src/bun.js/builtins/js/StreamInternals.js
@@ -252,7 +252,7 @@ function peekQueueValue(queue)
@assert(queue.content.isNotEmpty());
- return queue.peek().value;
+ return queue.peek()?.value;
}
function resetQueue(queue)
diff --git a/src/bun.js/builtins/js/WritableStreamInternals.js b/src/bun.js/builtins/js/WritableStreamInternals.js
index 5a97155f2..58c4ee87c 100644
--- a/src/bun.js/builtins/js/WritableStreamInternals.js
+++ b/src/bun.js/builtins/js/WritableStreamInternals.js
@@ -714,10 +714,12 @@ function writableStreamDefaultControllerAdvanceQueueIfNeeded(controller)
return;
}
- if (@getByIdDirectPrivate(controller, "queue").content?.isEmpty() ?? false)
+ const queue = @getByIdDirectPrivate(controller, "queue");
+
+ if (queue.content?.isEmpty() ?? false)
return;
- const value = @peekQueueValue(@getByIdDirectPrivate(controller, "queue"));
+ const value = @peekQueueValue(queue);
if (value === @isCloseSentinel)
@writableStreamDefaultControllerProcessClose(controller);
else