diff --git a/plugins/http/guest-js/index.ts b/plugins/http/guest-js/index.ts
index 424c3871..6b48e730 100644
--- a/plugins/http/guest-js/index.ts
+++ b/plugins/http/guest-js/index.ts
@@ -193,7 +193,6 @@ export async function fetch(
         // close early if aborted
         if (signal?.aborted) {
           controller.error(ERROR_REQUEST_CANCELLED)
-          controller.close()
           return
         }
 
@@ -214,10 +213,10 @@ export async function fetch(
 
       // run a non-blocking body stream fetch
       invoke('plugin:http|fetch_stream_body', {
+        rid,
         streamChannel
       }).catch((e) => {
         controller.error(e)
-        controller.close()
       })
     }
   })