(host, port, msg)
| 938 | import asyncio |
| 939 | |
| 940 | async def do_echo(host, port, msg): |
| 941 | reader, writer = await asyncio.open_connection(host, port) |
| 942 | writer.write(msg) |
| 943 | await writer.drain() |
| 944 | data = await reader.read(1024) |
| 945 | writer.close() |
| 946 | return data.decode() |
| 947 | |
| 948 | r1, r2 = await asyncio.gather( |
| 949 | do_echo(host1, port1, b"conn1"), |