(message: dict[str, Any])
| 1311 | return await _lifespan_receive_queue.get() |
| 1312 | |
| 1313 | async def send(message: dict[str, Any]) -> None: |
| 1314 | await _lifespan_send_queue.put(message) |
| 1315 | |
| 1316 | # Start the lifespan coroutine as a background task. |
| 1317 | # Store in outer scope to prevent GC (event loop holds weak refs). |
no test coverage detected