aboutsummaryrefslogtreecommitdiff
path: root/src/js/builtins/ReadableByteStreamInternals.ts
diff options
context:
space:
mode:
authorGravatar dave caruso <me@paperdave.net> 2023-06-27 18:18:04 -0400
committerGravatar dave caruso <me@paperdave.net> 2023-06-29 23:37:20 -0400
commit4b27aaaac78de307f65a2e3359a0598363c25ad1 (patch)
tree9c5630734d5b69b6de763210dd39cc8a5faa45a2 /src/js/builtins/ReadableByteStreamInternals.ts
parent8fbf24fc2fcca36fa78f36c7fd21f729c46c5cdb (diff)
downloadbun-4b27aaaac78de307f65a2e3359a0598363c25ad1.tar.gz
bun-4b27aaaac78de307f65a2e3359a0598363c25ad1.tar.zst
bun-4b27aaaac78de307f65a2e3359a0598363c25ad1.zip
call cancel properly and lightly clean up ReadableStream
Diffstat (limited to 'src/js/builtins/ReadableByteStreamInternals.ts')
-rw-r--r--src/js/builtins/ReadableByteStreamInternals.ts4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/js/builtins/ReadableByteStreamInternals.ts b/src/js/builtins/ReadableByteStreamInternals.ts
index f44c385b4..84186c628 100644
--- a/src/js/builtins/ReadableByteStreamInternals.ts
+++ b/src/js/builtins/ReadableByteStreamInternals.ts
@@ -133,7 +133,7 @@ export function readableByteStreamControllerClose(controller) {
var first = $getByIdDirectPrivate(controller, "pendingPullIntos")?.peek();
if (first) {
if (first.bytesFilled > 0) {
- const e = $makeTypeError("Close requested while there remain pending bytes");
+ const e = new TypeError("Close requested while there remain pending bytes");
$readableByteStreamControllerError(controller, e);
throw e;
}
@@ -629,7 +629,7 @@ export function readableByteStreamControllerPullInto(controller, view) {
return $createFulfilledPromise({ value: filledView, done: false });
}
if ($getByIdDirectPrivate(controller, "closeRequested")) {
- const e = $makeTypeError("Closing stream has been requested");
+ const e = new TypeError("Closing stream has been requested");
$readableByteStreamControllerError(controller, e);
return Promise.$reject(e);
}