[PR #10426/fae142f5 backport][3.11] Add benchmark for streaming API iter_chunks (#10427)

Co-authored-by: J. Nick Koston <[email protected]>

Author: patchback[bot]

tests/test_benchmarks_client.py

@@ -124,7 +124,7 @@ def test_one_hundred_get_requests_with_512kib_chunked_payload(
     aiohttp_client: AiohttpClient,
     benchmark: BenchmarkFixture,
 ) -> None:
-    """Benchmark 100 GET requests with a payload of 512KiB."""
+    """Benchmark 100 GET requests with a payload of 512KiB using read."""
     message_count = 100
     payload = b"a" * (2**19)
 
@@ -148,6 +148,36 @@ def _run() -> None:
         loop.run_until_complete(run_client_benchmark())
 
 
+def test_one_hundred_get_requests_iter_chunks_on_512kib_chunked_payload(
+    loop: asyncio.AbstractEventLoop,
+    aiohttp_client: AiohttpClient,
+    benchmark: BenchmarkFixture,
+) -> None:
+    """Benchmark 100 GET requests with a payload of 512KiB using iter_chunks."""
+    message_count = 100
+    payload = b"a" * (2**19)
+
+    async def handler(request: web.Request) -> web.Response:
+        resp = web.Response(body=payload)
+        resp.enable_chunked_encoding()
+        return resp
+
+    app = web.Application()
+    app.router.add_route("GET", "/", handler)
+
+    async def run_client_benchmark() -> None:
+        client = await aiohttp_client(app)
+        for _ in range(message_count):
+            resp = await client.get("/")
+            async for _ in resp.content.iter_chunks():
+                pass
+        await client.close()
+
+    @benchmark
+    def _run() -> None:
+        loop.run_until_complete(run_client_benchmark())
+
+
 def test_get_request_with_251308_compressed_chunked_payload(
     loop: asyncio.AbstractEventLoop,
     aiohttp_client: AiohttpClient,