Python 3.7 Asyncio Echo Server

async_echo_server.py

import asyncio

class EchoProtocol(asyncio.Protocol):

    def __init__(self):
        self.transport = None

    def connection_made(self, transport):
        peer_name = transport.get_extra_info("peername")
        print(f"Connection from {peer_name[0]}")
        self.transport = transport

    def data_received(self, data):
        data = data.decode().replace("\n", "").encode()
        self.transport.write(data)


loop = asyncio.get_event_loop()
coro = loop.create_server(EchoProtocol, "localhost", 8990)
server = loop.run_until_complete(coro)
try:
    loop.run_forever()
except StopIteration:
    loop.run_until_complete(server.wait_closed())
except KeyboardInterrupt:
    loop.close()
finally:
    loop.close()