diff options
Diffstat (limited to 'src/bun.js/builtins/js/ReadableStreamInternals.js')
-rw-r--r-- | src/bun.js/builtins/js/ReadableStreamInternals.js | 12 |
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) { |