(address, handler)
| 53 | return getattr(self.sock, name) |
| 54 | |
| 55 | async def tcp_server(address, handler): |
| 56 | sock = GenSocket(socket(AF_INET, SOCK_STREAM)) |
| 57 | sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) |
| 58 | sock.bind(address) |
| 59 | sock.listen(5) |
| 60 | while True: |
| 61 | client, addr = await sock.accept() |
| 62 | tasks.append(handler(client, addr)) |
| 63 | |
| 64 | async def echo_handler(client, address): |
| 65 | print('Connection from', address) |
no test coverage detected