История изменений

import asyncio
import aiohttp


URL = 'http://rtmp.domain.tld:2300'


async def check(url, chunk_size, timeout_sec):
    timeout = aiohttp.ClientTimeout(total=timeout_sec)
    async with aiohttp.ClientSession() as session:
        async with session.get(url, timeout=timeout) as resp:
            content = await resp.content.read(chunk_size)
            assert chunk_size == len(content)


asyncio.run(check(URL, 256, 5))

import asyncio
import aiohttp


URL = 'http://rtmp.domain.tld:2300'


async def check(url, chunk_size):
    async with aiohttp.ClientSession() as session:
        async with session.get(url) as resp:
            content = await resp.content.read(chunk_size)
            assert chunk_size == len(content)


asyncio.run(check(URL, 256))