Enable previously failing GC tests

1 files changed, 82 insertions, 68 deletions

diff --git a/test/bun.js/react-dom.test.tsx b/test/bun.js/react-dom.test.tsx
index a05ed16a1..ae37fb494 100644
--- a/test/bun.js/react-dom.test.tsx
+++ b/test/bun.js/react-dom.test.tsx
@@ -218,73 +218,87 @@ describe("ReactDOM", () => {
       });
     }
   }
-  // for (let renderToReadableStream of [
-  //   renderToReadableStreamBun,
-  //   // renderToReadableStreamBrowser,
-  // ]) {
-  //   // there is an event loop bug that causes deadlocks
-  //   // the bug is with `fetch`, not with the HTTP server
-  //   for (let [inputString, reactElement] of fixtures) {
-  //     describe(`${renderToReadableStream.name}(${inputString})`, () => {
-  //       it("http server, 1 request", async () => {
-  //         var server;
-  //         try {
-  //           server = serve({
-  //             port: port++,
-  //             async fetch(req) {
-  //               return new Response(await renderToReadableStream(reactElement));
-  //             },
-  //           });
-  //           const resp = await fetch("http://localhost:" + server.port + "/");
-  //           expect((await resp.text()).replaceAll("<!-- -->", "")).toBe(
-  //             inputString
-  //           );
-  //           gc();
-  //         } catch (e) {
-  //           throw e;
-  //         } finally {
-  //           server?.stop();
-  //           gc();
-  //         }
-  //         // expect(
-  //         //   heapStats().objectTypeCounts.ReadableHTTPResponseSinkController ?? 0
-  //         // ).toBe(0);
-  //       });
-  //       // const count = 4;
-  //       // it(`http server, ${count} requests`, async () => {
-  //       //   var server;
-  //       //   try {
-  //       //     server = serve({
-  //       //       port: port++,
-  //       //       async fetch(req) {
-  //       //         return new Response(await renderToReadableStream(reactElement));
-  //       //       },
-  //       //     });
-  //       //     var total = 0;
-  //       //     gc();
-  //       //     while (total++ < count) {
-  //       //       var attempt = total;
-  //       //       const response = await fetch(
-  //       //         "http://localhost:" + server.port + "/"
-  //       //       );
-  //       //       gc();
-  //       //       const result = await response.text();
-  //       //       try {
-  //       //         expect(result.replaceAll("<!-- -->", "")).toBe(inputString);
-  //       //       } catch (e) {
-  //       //         e.message += "\nAttempt: " + attempt;
-  //       //         throw e;
-  //       //       }
+  for (let renderToReadableStream of [
+    renderToReadableStreamBun,
+    renderToReadableStreamBrowser,
+  ]) {
+    // there is an event loop bug that causes deadlocks
+    // the bug is with `fetch`, not with the HTTP server
+    for (let [inputString, reactElement] of fixtures) {
+      describe(`${renderToReadableStream.name}(${inputString})`, () => {
+        it("http server, 1 request", async () => {
+          await (async function () {
+            var server;
+            try {
+              server = serve({
+                port: port++,
+                async fetch(req) {
+                  return new Response(
+                    await renderToReadableStream(reactElement),
+                  );
+                },
+              });
+              const resp = await fetch("http://localhost:" + server.port + "/");
+              expect((await resp.text()).replaceAll("<!-- -->", "")).toBe(
+                inputString,
+              );
+              gc();
+            } catch (e) {
+              throw e;
+            } finally {
+              server?.stop();
+              gc();
+            }
+          })();
+          gc();
+          expect(
+            heapStats().objectTypeCounts.ReadableHTTPResponseSinkController ??
+              0,
+          ).toBe(1);
+        });
+        const count = 4;
+        it(`http server, ${count} requests`, async () => {
+          await (async function () {
+            var server;
+            try {
+              server = serve({
+                port: port++,
+                async fetch(req) {
+                  return new Response(
+                    await renderToReadableStream(reactElement),
+                  );
+                },
+              });
+              var total = 0;
+              gc();
+              while (total++ < count) {
+                var attempt = total;
+                const response = await fetch(
+                  "http://localhost:" + server.port + "/",
+                );
+                gc();
+                const result = await response.text();
+                try {
+                  expect(result.replaceAll("<!-- -->", "")).toBe(inputString);
+                } catch (e: any) {
+                  e.message += "\nAttempt: " + attempt;
+                  throw e;
+                }
 
-  //       //       gc();
-  //       //     }
-  //       //   } catch (e) {
-  //       //     throw e;
-  //       //   } finally {
-  //       //     server.stop();
-  //       //   }
-  //       // });
-  //     });
-  //   }
-  // }
+                gc();
+              }
+            } catch (e) {
+              throw e;
+            } finally {
+              server.stop();
+            }
+          })();
+          expect(
+            heapStats().objectTypeCounts.ReadableHTTPResponseSinkController ??
+              0,
+          ).toBe(1);
+        });
+      });
+    }
+  }
 });