aiotools_async_echo_server_with_graceful_termination.py

1import asyncio
2import aiotools
3
4async def echo(reader, writer):
5    data = await reader.read(100)
6    writer.write(data)
7    await writer.drain()
8    writer.close()
9    await writer.wait_closed()
10
11async def main():
12    async with aiotools.start_server(echo, 'localhost', 8888) as server:
13        print(f'Serving on {server.sockets[0].getsockname()}')
14        await server.serve_forever()
15
16if __name__ == '__main__':
17    # aiotools.act_as_main() automatically handles 
18    # SIGINT/SIGTERM and cleans up the event loop.
19    aiotools.act_as_main(main())