(sock, addr)
| 23 | HELLO_MSG = b'1' * 1024 * 5 + b'\n' |
| 24 | |
| 25 | def client(sock, addr): |
| 26 | for i in range(10): |
| 27 | time.sleep(0.2) |
| 28 | if srv.is_serving(): |
| 29 | break |
| 30 | else: |
| 31 | raise RuntimeError |
| 32 | |
| 33 | sock.settimeout(2) |
| 34 | sock.connect(addr) |
| 35 | sock.send(HELLO_MSG) |
| 36 | sock.recv_all(1) |
| 37 | sock.close() |
| 38 | |
| 39 | async def serve(reader, writer): |
| 40 | await reader.readline() |
nothing calls this directly
no test coverage detected