aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-19 23:37:52 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-11-19 23:37:52 -0800
commit2f1e9b2eb8ab4f210dd356735f5b610deb89987b (patch)
tree45067ccc7a4ae7d61e73f0f08c98840ac87ec4ba /src
parentc68b11e8cbf493723d0b2e029fe6e10d1fe7e83d (diff)
downloadbun-2f1e9b2eb8ab4f210dd356735f5b610deb89987b.tar.gz
bun-2f1e9b2eb8ab4f210dd356735f5b610deb89987b.tar.zst
bun-2f1e9b2eb8ab4f210dd356735f5b610deb89987b.zip
[streams] Fix exception in `WritableStream`
cc @Electroid
Diffstat (limited to 'src')
-rw-r--r--src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp7
-rw-r--r--src/bun.js/builtins/js/StreamInternals.js5
2 files changed, 3 insertions, 9 deletions
diff --git a/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp b/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp
index 7886b5678..a957a7c2b 100644
--- a/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp
+++ b/src/bun.js/builtins/cpp/StreamInternalsBuiltins.cpp
@@ -362,16 +362,13 @@ const char* const s_streamInternalsEnqueueValueWithSizeCode =
const JSC::ConstructAbility s_streamInternalsPeekQueueValueCodeConstructAbility = JSC::ConstructAbility::CannotConstruct;
const JSC::ConstructorKind s_streamInternalsPeekQueueValueCodeConstructorKind = JSC::ConstructorKind::None;
const JSC::ImplementationVisibility s_streamInternalsPeekQueueValueCodeImplementationVisibility = JSC::ImplementationVisibility::Public;
-const int s_streamInternalsPeekQueueValueCodeLength = 116;
+const int s_streamInternalsPeekQueueValueCodeLength = 81;
static const JSC::Intrinsic s_streamInternalsPeekQueueValueCodeIntrinsic = JSC::NoIntrinsic;
const char* const s_streamInternalsPeekQueueValueCode =
"(function (queue)\n" \
"{\n" \
" \"use strict\";\n" \
- "\n" \
- " @assert(queue.content.isNotEmpty());\n" \
- "\n" \
- " return queue.peek()?.value;\n" \
+ " return queue.content.peek()?.value;\n" \
"})\n" \
;
diff --git a/src/bun.js/builtins/js/StreamInternals.js b/src/bun.js/builtins/js/StreamInternals.js
index 5e447c29c..78bcdcfb3 100644
--- a/src/bun.js/builtins/js/StreamInternals.js
+++ b/src/bun.js/builtins/js/StreamInternals.js
@@ -256,10 +256,7 @@ function enqueueValueWithSize(queue, value, size)
function peekQueueValue(queue)
{
"use strict";
-
- @assert(queue.content.isNotEmpty());
-
- return queue.peek()?.value;
+ return queue.content.peek()?.value;
}
function resetQueue(queue)