# 项目文件：demos/httpx_async.py
# get 的网络等待交给事件循环；响应读完后 json() 是普通解析调用，不需要 await。
import asyncio

import httpx
from labserver import running_server


async def read_all(base_url):
    async with httpx.AsyncClient(
        base_url=base_url, timeout=1, trust_env=False
    ) as client:
        async with asyncio.TaskGroup() as group:
            tasks = [
                group.create_task(
                    client.get(f"/api/books/{number}", params={"delay": 0.02})
                )
                for number in [1, 2, 3]
            ]
        records = []
        for task in tasks:
            response = task.result()
            response.raise_for_status()
            records.append(response.json())
    return [record["title"] for record in records]


if __name__ == "__main__":
    with running_server() as server:
        print(asyncio.run(read_all(server.base_url)))