(client, address)
| 62 | tasks.append(handler(client, addr)) |
| 63 | |
| 64 | async def echo_handler(client, address): |
| 65 | print('Connection from', address) |
| 66 | while True: |
| 67 | data = await client.recv(1000) |
| 68 | if not data: |
| 69 | break |
| 70 | await client.send(b'GOT:' + data) |
| 71 | print('Connection closed') |
| 72 | |
| 73 | if __name__ == '__main__': |
| 74 | tasks.append(tcp_server(('',25000), echo_handler)) |