aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/js/ReadableStream.js
diff options
context:
space:
mode:
authorGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-12-28 04:24:07 -0800
committerGravatar Jarred Sumner <709451+Jarred-Sumner@users.noreply.github.com> 2022-12-28 04:24:07 -0800
commit66234d9d575f71e190a2916f5326480db85c5160 (patch)
tree94c45a0cba8c700dc57610c471184dd0fddd6808 /src/bun.js/builtins/js/ReadableStream.js
parent3d60b870ee0d206d79eb4dda22dec7da55d91184 (diff)
downloadbun-66234d9d575f71e190a2916f5326480db85c5160.tar.gz
bun-66234d9d575f71e190a2916f5326480db85c5160.tar.zst
bun-66234d9d575f71e190a2916f5326480db85c5160.zip
Move some code up
Diffstat (limited to 'src/bun.js/builtins/js/ReadableStream.js')
-rw-r--r--src/bun.js/builtins/js/ReadableStream.js11
1 files changed, 4 insertions, 7 deletions
diff --git a/src/bun.js/builtins/js/ReadableStream.js b/src/bun.js/builtins/js/ReadableStream.js
index cd5cf5a44..1449c836d 100644
--- a/src/bun.js/builtins/js/ReadableStream.js
+++ b/src/bun.js/builtins/js/ReadableStream.js
@@ -381,7 +381,10 @@ function pipeTo(destination)
{
"use strict";
if (!@isReadableStream(this))
- throw @makeTypeError("readable should be ReadableStream");
+ return @Promise.@reject(@makeThisTypeError("ReadableStream", "pipeTo"));
+
+ if (@isReadableStreamLocked(this))
+ return @Promise.@reject(@makeTypeError("ReadableStream is locked"));
// FIXME: https://bugs.webkit.org/show_bug.cgi?id=159869.
// Built-in generator should be able to parse function signature to compute the function length correctly.
@@ -413,12 +416,6 @@ function pipeTo(destination)
if (!@isWritableStream(internalDestination))
return @Promise.@reject(@makeTypeError("ReadableStream pipeTo requires a WritableStream"));
- if (!@isReadableStream(this))
- return @Promise.@reject(@makeThisTypeError("ReadableStream", "pipeTo"));
-
- if (@isReadableStreamLocked(this))
- return @Promise.@reject(@makeTypeError("ReadableStream is locked"));
-
if (@isWritableStreamLocked(internalDestination))
return @Promise.@reject(@makeTypeError("WritableStream is locked"));