diff options
author | 2023-06-27 18:18:04 -0400 | |
---|---|---|
committer | 2023-06-29 23:37:20 -0400 | |
commit | 4b27aaaac78de307f65a2e3359a0598363c25ad1 (patch) | |
tree | 9c5630734d5b69b6de763210dd39cc8a5faa45a2 /src/js/builtins/ReadableByteStreamInternals.ts | |
parent | 8fbf24fc2fcca36fa78f36c7fd21f729c46c5cdb (diff) | |
download | bun-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.ts | 4 |
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); } |