Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import asyncio
- import aiohttp
- async def handle_echo(reader, writer):
- data = await reader.read(100)
- message = data.decode()
- addr = writer.get_extra_info('peername')
- print("Received %r from %r" % (message, addr))
- print("Send: %r" % message)
- writer.write(data)
- await writer.drain()
- print("Close")
- writer.close()
- loop = asyncio.get_event_loop()
- coro = asyncio.start_server(handle_echo, '127.0.0.1', int(1234), loop=loop)
- server = loop.run_until_complete(coro)
- print('Serving on {}'.format(server.sockets[0].getsockname()))
- try:
- loop.run_forever()
- except KeyboardInterrupt:
- pass
- server.close()
- loop.run_until_complete(server.wait_closed())
- loop.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement