resolve tests

Author: RulaKhaled

packages/cloudflare/src/request.ts

@@ -126,15 +126,9 @@ export function wrapRequestHandler(
             // Monitor stream consumption and end span when complete
             const streamMonitor = (async () => {
               const reader = monitorStream.getReader();
-              let spanEnded = false;
 
-              // Safety timeout - end span after 30s even if stream hasn't finished
-              const timeout = setTimeout(() => {
-                if (!spanEnded) {
-                  spanEnded = true;
-                  span.end();
-                }
-              }, 5000);
+              // Safety timeout - abort reading and end span after 5s even if stream hasn't finished
+              const timeout = setTimeout(() => reader.cancel(), 5000);
 
               try {
                 let done = false;
@@ -147,9 +141,7 @@ export function wrapRequestHandler(
               } finally {
                 clearTimeout(timeout);
                 reader.releaseLock();
-                if (!spanEnded) {
-                  span.end();
-                }
+                span.end();
               }
             })();