Function _gen

uncommon_route/proxy.py:3771–3784

()

        queue = await bus.subscribe()

        async def _gen() -> AsyncGenerator[bytes, None]:
            yield b": connected\n\n"
            try:
                while True:
                    if await request.is_disconnected():
                        break
                    try:
                        event = await asyncio.wait_for(queue.get(), timeout=15.0)
                        payload = json.dumps(event, default=str)
                        yield f"data: {payload}\n\n".encode("utf-8")
                    except asyncio.TimeoutError:
                        yield b": keepalive\n\n"
            finally:
                await bus.unsubscribe(queue)

        return StreamingResponse(
            _gen(),