()
| 570 | ](max_buffer_size=1) |
| 571 | |
| 572 | async def _producer() -> None: |
| 573 | async with send_stream: |
| 574 | async for raw_item in sse_aiter: |
| 575 | await send_stream.send(_serialize_sse_item(raw_item)) |
| 576 | |
| 577 | send_keepalive, receive_keepalive = ( |
| 578 | anyio.create_memory_object_stream[bytes](max_buffer_size=1) |
nothing calls this directly
no test coverage detected
searching dependent graphs…