From ea6a2bf0c6c1d485435aff4ead8ad8835d781347 Mon Sep 17 00:00:00 2001
From: Yusuke Wada <yusuke@kamawada.com>
Date: Mon, 2 Nov 2026 18:51:50 +0900
Subject: [PATCH] test: wait for the first chunk before sending the second in
 the readable-stream test

---
 test/server.test.ts | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/test/server.test.ts b/test/server.test.ts
index 560a887..274dc90 100644
--- a/test/server.test.ts
+++ b/test/server.test.ts
@@ -186,6 +186,7 @@ describe('various response body types', () => {
     const largeText = 'a'.repeat(1024 * 1024 * 10)
     let server: ServerType
     let resolveReadableStreamPromise: () => void
+    let resolveReadableStreamSecondChunkPromise: () => void
     let resolveEventStreamPromise: () => void
     let resolveEventStreamWithoutTransferEncodingPromise: () => void
     beforeAll(() => {
@@ -223,11 +224,15 @@ describe('various response body types', () => {
       const readableStreamPromise = new Promise<void>((resolve) => {
         resolveReadableStreamPromise = resolve
       })
+      const readableStreamSecondChunkPromise = new Promise<void>((resolve) => {
+        resolveReadableStreamSecondChunkPromise = resolve
+      })
       app.get('/readable-stream', () => {
         const stream = new ReadableStream({
           async start(controller) {
             await readableStreamPromise
             controller.enqueue('Hello!')
+            await readableStreamSecondChunkPromise
             controller.enqueue(' Node!')
             controller.close()
           },
@@ -376,6 +381,11 @@ describe('various response body types', () => {
             expect(headers.get('transfer-encoding')).toBe('chunked')
             resolveReadableStreamPromise()
           },
+          onChunk: (_chunk, index) => {
+            if (index === 0) {
+              resolveReadableStreamSecondChunkPromise()
+            }
+          },
         }
       )
       expect(res.status).toBe(200)