aboutsummaryrefslogtreecommitdiff
path: root/src/bun.js/builtins/js/ReadableStreamInternals.js
diff options
context:
space:
mode:
Diffstat (limited to 'src/bun.js/builtins/js/ReadableStreamInternals.js')
-rw-r--r--src/bun.js/builtins/js/ReadableStreamInternals.js12
1 files changed, 11 insertions, 1 deletions
diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js
index cbe72c99e..e59372d24 100644
--- a/src/bun.js/builtins/js/ReadableStreamInternals.js
+++ b/src/bun.js/builtins/js/ReadableStreamInternals.js
@@ -1614,7 +1614,17 @@ function readableStreamCancel(stream, reason) {
@readableStreamClose(stream);
var controller = @getByIdDirectPrivate(stream, "readableStreamController");
- return controller.@cancel(controller, reason).@then(function () {});
+ var cancel = controller.@cancel;
+ if (cancel) {
+ return cancel(controller, reason).@then(function () {});
+ }
+
+ var close = controller.close;
+ if (close) {
+ return @Promise.@resolve(controller.close(reason));
+ }
+
+ @throwTypeError("ReadableStreamController has no cancel or close method");
}
function readableStreamDefaultControllerCancel(controller, reason) {