my_aecho.py

#!/usr/bin/env python3
# -*- coding: utf-8 -*-

# pecho.py

from socket import *
import my_asyncio

loop = my_asyncio.Loop()


async def echo_server(address):
    sock = socket(AF_INET, SOCK_STREAM)
    sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
    sock.bind(address)
    sock.listen(5)
    sock.setblocking(False)
    while True:
        client, addr = await loop.sock_accept(sock)
        print("Connection from", addr)
        loop.create_task(echo_handler(client))


async def echo_handler(client):
    with client:
        while True:
            data = await loop.sock_recv(client, 10000)
            if not data:
                break

            await loop.sock_sendall(client, b"Got:" + data)
    print("Connection closed")


loop.create_task(echo_server(("", 25000)))
loop.run_forever()