Skip to content

Commit 9bae78c

Browse files
committed
Fix AsyncBytesReader, read when bytes are already available
1 parent e649340 commit 9bae78c

File tree

1 file changed

+5
-4
lines changed
  • packages/smithy-core/src/smithy_core/aio

1 file changed

+5
-4
lines changed

packages/smithy-core/src/smithy_core/aio/types.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -72,10 +72,11 @@ async def _read_from_iterable(
7272
self._remainder = b""
7373
return result
7474

75-
async for element in iterator:
76-
result += element
77-
if len(result) >= size:
78-
break
75+
if len(result) < size:
76+
async for element in iterator:
77+
result += element
78+
if len(result) >= size:
79+
break
7980

8081
self._remainder = result[size:]
8182
return result[:size]

0 commit comments

Comments
 (0)