Skip to content

Commit 6512aaa

Browse files
authored
Use anext in AsyncIterablePayload on Python 3.10+ (#10941)
1 parent 77c0115 commit 6512aaa

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

CHANGES/10941.bugfix.rst

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
10915.bugfix.rst

aiohttp/payload.py

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -810,7 +810,10 @@ async def write_with_length(
810810

811811
try:
812812
while True:
813-
chunk = await self._iter.__anext__()
813+
if sys.version_info >= (3, 10):
814+
chunk = await anext(self._iter)
815+
else:
816+
chunk = await self._iter.__anext__()
814817
if remaining_bytes is None:
815818
await writer.write(chunk)
816819
# If we have a content length limit

0 commit comments

Comments
 (0)