learning asyncio in practice

asyncio_socket_server.py

# server made with asyncio
# flake8: noqa


import asyncio
from socket import (socket, AF_INET, SOCK_STREAM, SO_REUSEADDR, SOL_SOCKET)


async def start_server(sock):
    server = await loop.create_server(asyncio.Protocol, sock=sock)
    print(dir(server))
    print('server started ?')


async def poll(sock):
    conn, addr = await loop.sock_accept(sock)
    loop.sock_sendall(conn, b'welcome')
    while True:
        data = await loop.sock_recv(conn, 1024)
        print('Got:', data)


loop = asyncio.get_event_loop()

sock = socket(AF_INET, SOCK_STREAM)
sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
sock.bind(('0.0.0.0', 8888))

loop.create_task(loop.create_server(asyncio.Protocol, sock=sock))
loop.create_task(poll(sock))
loop.run_forever()

server.py

# -*- coding: utf-8 -*-
#
# server.py
#

from socket import (socket, AF_INET, SOCK_STREAM, SO_REUSEADDR, SOL_SOCKET)


sock = socket(AF_INET, SOCK_STREAM)
# sock.setsockopt(SOL_SOCKET, SO_REUSEADDR, 1)
sock.bind(('0.0.0.0', 8888))
sock.listen()

print('Server started')
conn, addr = sock.accept()
conn.sendall(b'hello world')
print('Connection from: ', addr)

for i in range(0, 10):
    data = conn.recv(1024)
    print('Recv:', data)
    if data == 'exit':
        conn.close()
        break
else:
    conn.close()

sock.close()