Skip to content

Commit

Permalink
rename executeStreamIterator
Browse files Browse the repository at this point in the history
  • Loading branch information
Cito committed Apr 7, 2024
1 parent bce7a3d commit 0974548
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions src/graphql/execution/execute.py
Original file line number Diff line number Diff line change
Expand Up @@ -1242,7 +1242,7 @@ async def complete_async_iterator_value(
with suppress(TimeoutError):
await wait_for(
shield(
self.execute_stream_iterator(
self.execute_stream_async_iterator(
index,
iterator,
field_group,
Expand Down Expand Up @@ -1859,7 +1859,7 @@ async def await_completed_items() -> list[Any] | None:
async_payload_record.add_items(completed_items)
return async_payload_record

async def execute_stream_iterator_item(
async def execute_stream_async_iterator_item(
self,
iterator: AsyncIterator[Any],
field_group: FieldGroup,
Expand Down Expand Up @@ -1893,7 +1893,7 @@ async def execute_stream_iterator_item(
)
self.filter_subsequent_payloads(item_path, async_payload_record)

async def execute_stream_iterator(
async def execute_stream_async_iterator(
self,
initial_index: int,
iterator: AsyncIterator[Any],
Expand All @@ -1915,7 +1915,7 @@ async def execute_stream_iterator(
)

try:
data = await self.execute_stream_iterator_item(
data = await self.execute_stream_async_iterator_item(
iterator,
field_group,
info,
Expand Down

0 comments on commit 0974548

Please sign in to comment.