From 157c6ffe85249c912015ad7622f34c3adb9bc611 Mon Sep 17 00:00:00 2001
From: Jarred Sumner <jarred@jarredsumner.com>
Date: Fri, 27 Sep 2024 03:34:31 -0700
Subject: [PATCH] Update fetch-tcp-stress.test.ts

---
 test/js/web/fetch/fetch-tcp-stress.test.ts | 14 ++++++++------
 1 file changed, 8 insertions(+), 6 deletions(-)

diff --git a/test/js/web/fetch/fetch-tcp-stress.test.ts b/test/js/web/fetch/fetch-tcp-stress.test.ts
index 5872cac4df2dc..a66a80c7204f7 100644
--- a/test/js/web/fetch/fetch-tcp-stress.test.ts
+++ b/test/js/web/fetch/fetch-tcp-stress.test.ts
@@ -42,7 +42,7 @@ async function runStressTest({
             socket.data ??= {};
             socket.data.read = true;
             sockets[i] = socket;
-            if (socket.write("200 OK\r\nCo") === "200 OK\r\nCo".length) {
+            if (socket.write("200 OK\r\n\r\n") === "200 OK\r\n\r\n".length) {
               socket.data.written = true;
               onServerWritten(socket);
             }
@@ -56,7 +56,7 @@ async function runStressTest({
             return;
           }
 
-          if (socket.write("200 OK\r\nCo") === "200 OK\r\nCo".length) {
+          if (socket.write("200 OK\r\n\r\n") === "200 OK\r\n\r\n".length) {
             socket.data.written = true;
             onServerWritten(socket);
           }
@@ -81,9 +81,11 @@ async function runStressTest({
         toClose = batch;
         for (let i = 0; i < batch; i++) {
           promises.push(
-            fetch(`http://127.0.0.1:${server.port}`, objects[i]).finally(() => {
-              onFetchWritten(sockets[i]);
-            }),
+            fetch(`http://127.0.0.1:${server.port}`, objects[i])
+              .then(r => r.blob())
+              .finally(() => {
+                onFetchWritten(sockets[i]);
+              }),
           );
         }
         await Promise.allSettled(promises);
@@ -120,7 +122,7 @@ test(
   async () => {
     await runStressTest({
       onServerWritten(socket) {
-        socket.end();
+        socket.shutdown();
       },
       onFetchWritten(socket) {},
     });