import asyncio

async def handle_echo(reader, writer):
    data = await reader.read(1024)
    message = data.decode()
    addr = writer.get_extra_info("peername")
    print(f"received {message} from {addr}")
    writer.close()

loop = asyncio.get_event_loop()
coro = asyncio.start_server(handle_echo, "127.0.0.1", 10001, loop=loop)
server = loop.run_until_complete(coro)
try:
    loop.run_forever()
except KeyboardInterrupt:
    pass

server.close()
loop.run_untill_complete(server.wait_clossed())
loop.close()

#############################################################

import asyncio

async def echo_client(message, loop):
    reader, writer = await asyncio.open_connection("127.0.0.1", 10001, loop=loop)
    print(f"send: {message}")
    writer.write(message.encode())
    writer.close()
    await asyncio.sleep(1.0)

loop = asyncio.get_event_loop()

message = "Shalom World!"
loop.run_until_complete(echo_client(message, loop))

while True:
    loop.run_until_complete(echo_client(message, loop))

loop.close()