Function body

tests/units/utils/test_streaming_response.py:19–24

()

    on_finish = AsyncMock()

    async def body():
        try:
            yield b"payload"
            await asyncio.Event().wait()
        finally:
            body_closed.set()

    async def receive() -> dict[str, Any]:
        await asyncio.Event().wait()