qh3_http3_client_get_request_with_async_streaming.py

1import asyncio
2from qh3 import connect
3
4async def main():
5    # Connect to an HTTP/3 server (example: cloudflare-quic.com)
6    async with connect("cloudflare-quic.com", 443) as connection:
7        # Perform a GET request
8        stream_id = connection.get_next_available_stream_id()
9        connection.send_headers(
10            stream_id,
11            [
12                (b":method", b"GET"),
13                (b":scheme", b"https"),
14                (b":authority", b"cloudflare-quic.com"),
15                (b":path", b"/"),
16            ],
17            end_stream=True,
18        )
19
20        # Wait for and print the response
21        async for event in connection:
22            if hasattr(event, "headers"):
23                print("Headers:", event.headers)
24            if hasattr(event, "data"):
25                print("Data:", event.data.decode())
26                if event.stream_ended:
27                    break
28
29if __name__ == "__main__":
30    asyncio.run(main())