async def METHOD_NAME(
    self,
    url: str,
    headers: Optional[Dict[str, Any]] = None,
    timeout: int = 30,
    chunk_size: int = 65536,
    raise_for_status: bool = True,
) -> AsyncGenerator[bytes, None]:
    if headers is None:
        headers = {}
    session = await self.create_session()
    async with session.get(
        url, timeout=timeout, headers=headers, raise_for_status=raise_for_status
    ) as resp:
        async for chunk in resp.content.iter_chunked(chunk_size):
            yield chunk