(address, handler)
| 49 | return getattr(self.sock, name) |
| 50 | |
| 51 | def tcp_server(address, handler): |
| 52 | sock = GenSocket(socket(AF_INET, SOCK_STREAM)) |
| 53 | sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1) |
| 54 | sock.bind(address) |
| 55 | sock.listen(5) |
| 56 | while True: |
| 57 | client, addr = yield from sock.accept() |
| 58 | tasks.append(handler(client, addr)) |
| 59 | |
| 60 | def echo_handler(client, address): |
| 61 | print('Connection from', address) |