Fix spurious unhandled promise rejection error

1 files changed, 5 insertions, 3 deletions

diff --git a/src/bun.js/builtins/js/ReadableStreamInternals.js b/src/bun.js/builtins/js/ReadableStreamInternals.js
index 3a02669dc..a6604a014 100644
--- a/src/bun.js/builtins/js/ReadableStreamInternals.js
+++ b/src/bun.js/builtins/js/ReadableStreamInternals.js
@@ -793,7 +793,8 @@ function readDirectStream(stream, sink, underlyingSource) {
   function close(stream, reason) {
     if (reason && underlyingSource?.cancel) {
       try {
-        underlyingSource.cancel(reason);
+        var prom = underlyingSource.cancel(reason);
+        @markPromiseAsHandled(prom);
       } catch (e) {
       }
 
@@ -890,7 +891,7 @@ async function readStreamIntoSink(stream, sink, isNative) {
     }
     var wroteCount = many.value.length;
     const highWaterMark = @getByIdDirectPrivate(stream, "highWaterMark");
-    if (isNative) @startDirectStream.@call(sink, stream, @undefined, () => !didThrow && stream.cancel());
+    if (isNative) @startDirectStream.@call(sink, stream, @undefined, () => !didThrow && @markPromiseAsHandled(stream.cancel()));
 
     if (highWaterMark) sink.start({ highWaterMark });
     
@@ -924,7 +925,8 @@ async function readStreamIntoSink(stream, sink, isNative) {
 
     try {
         reader = @undefined;
-        stream.cancel(e);
+        const prom = stream.cancel(e);
+        @markPromiseAsHandled(prom);
     } catch (j) {}
 
     if (sink && !didClose) {