()
| 83 | ev = AEvent() |
| 84 | |
| 85 | async def writer(): |
| 86 | # Wake up the socket, or let it time out, according to the expected `ready`. |
| 87 | await ev.wait() |
| 88 | assert port |
| 89 | await asleep(delay) |
| 90 | if ready == waiting.Ready.R: |
| 91 | with socket.create_connection(("127.0.0.1", port)): |
| 92 | pass |
| 93 | |
| 94 | tasks = [spawn(writer)] |
| 95 |