aiohttp_test_client.py

import asyncio
import aiohttp


async def download(session):
    async with session.get('http://localhost:8080/') as resp:
        while True:
            chunk = await resp.content.read(1024)
            # print(chunk)
            if not chunk:
                break
        print('status={code}'.format(code=resp.status))


async def run():
    session = aiohttp.ClientSession()
    downloaders = [download(session) for i in range(2)]
    await asyncio.gather(*downloaders)


loop = asyncio.get_event_loop()
loop.run_until_complete(asyncio.wait([run()]))