import asyncio
import logging


async def server_callback(reader: asyncio.StreamReader,
                          writer: asyncio.StreamWriter):
    print('Accepted')
    writer.write(b'hello')
    writer.transport.abort()


async def main():
    server = await asyncio.start_server(server_callback, '127.0.0.1', 28844)
    reader, writer = await asyncio.open_connection('127.0.0.1', 28844)
    for i in range(10):
        print(i)
        writer.write(b'\0'*65536)
        await writer.drain()
        await asyncio.sleep(0)

    writer.close()
    await writer.drain()
    server.close()
    await server.wait_closed()
    print('Finished')


if __name__ == '__main__':
    logger =logging.getLogger()
    logger.setLevel(logging.DEBUG)
    logger.addHandler(logging.StreamHandler())
    loop = asyncio.ProactorEventLoop()
    loop.set_debug(True)
    asyncio.set_event_loop(loop)
    loop.run_until_complete(main())