388th Commit

e2e/package.json

@@ -8,6 +8,7 @@
     "@playwright/test": "1.47.2",
     "@types/node": "20.16.10",
     "@types/ws": "8.5.12",
+    "fetch-event-stream": "0.1.5",
     "ws": "8.18.0"
   }
 }

e2e/src/sse.test.ts

@@ -0,0 +1,13 @@
+import { expect, test } from '@playwright/test';
+import { events } from 'fetch-event-stream';
+
+test('ES /api/sse', async ({ baseURL }) => {
+  const abortController = new AbortController();
+  const response = await fetch(`${baseURL}/api/sse`, { signal: abortController.signal });
+  const stream = events(response, abortController.signal);
+
+  for await (const event of stream) {
+    expect(event.data).toBe('Some message');
+    abortController.abort();
+  }
+});