(message: ASGISendEvent)
| 74 | return await queue.get() |
| 75 | |
| 76 | async def send(message: ASGISendEvent) -> None: |
| 77 | pass |
| 78 | |
| 79 | # This test fails if a timeout error is raised here |
| 80 | await asyncio.wait_for(connection(receive, send), timeout=1) |
no outgoing calls
no test coverage detected
searching dependent graphs…