--- a/examples/_run_server_child.py	Sat Mar 16 16:02:23 2024 -0700
+++ b/examples/_run_server_child.py	Mon Mar 18 16:42:21 2024 -0700
@@ -1,8 +1,14 @@
 import asyncio
+import contextlib
+import logging
 from dataclasses import dataclass
+from datetime import timedelta
 from pathlib import Path
 
 import aiohttp
+from aiohttp_sse_client import client as sse_client
+
+log = logging.getLogger('chil')
 
 
 @dataclass
@@ -26,3 +32,19 @@
                 return await self._session.get(url, headers=headers)
             except aiohttp.ClientConnectorError:
                 await asyncio.sleep(0.05)
+
+    @contextlib.asynccontextmanager
+    async def eventSource(self, url: str):
+        async with sse_client.EventSource(
+                url, reconnection_time=timedelta(seconds=.05)) as es:
+            yield es
+
+
+async def assert_event_stream_starts_with(http_server, url, expected_events):
+    events_left = expected_events[:]
+    async with http_server.eventSource(url) as es:
+        async for event in es:
+            assert (event.message, event.data) == events_left[0]
+            events_left.pop(0)
+            if not events_left:
+                break