polish: rename MapAsyncIterator to MapAsyncIterable

Replicates graphql/graphql-js@4822cb4

Author: Cito

docs/conf.py

@@ -148,7 +148,7 @@
 GraphQLOutputType
 Middleware
 asyncio.events.AbstractEventLoop
-graphql.execution.map_async_iterator.MapAsyncIterator
+graphql.execution.map_async_iterable.MapAsyncIterable
 graphql.execution.Middleware
 graphql.language.lexer.EscapeSequence
 graphql.language.visitor.EnterLeaveVisitor

docs/modules/execution.rst

@@ -26,7 +26,7 @@ Execution
 
 .. autofunction:: create_source_event_stream
 
-.. autoclass:: MapAsyncIterator
+.. autoclass:: MapAsyncIterable
 
 .. autoclass:: Middleware
 

src/graphql/__init__.py

@@ -437,7 +437,7 @@
     # Subscription
     subscribe,
     create_source_event_stream,
-    MapAsyncIterator,
+    MapAsyncIterable,
     # Middleware
     Middleware,
     MiddlewareManager,
@@ -703,7 +703,7 @@
     "MiddlewareManager",
     "subscribe",
     "create_source_event_stream",
-    "MapAsyncIterator",
+    "MapAsyncIterable",
     "validate",
     "ValidationContext",
     "ValidationRule",

src/graphql/execution/__init__.py

@@ -16,7 +16,7 @@
     FormattedExecutionResult,
     Middleware,
 )
-from .map_async_iterator import MapAsyncIterator
+from .map_async_iterable import MapAsyncIterable
 from .middleware import MiddlewareManager
 from .values import get_argument_values, get_directive_values, get_variable_values
 
@@ -30,7 +30,7 @@
     "ExecutionContext",
     "ExecutionResult",
     "FormattedExecutionResult",
-    "MapAsyncIterator",
+    "MapAsyncIterable",
     "Middleware",
     "MiddlewareManager",
     "get_argument_values",

src/graphql/execution/execute.py

@@ -59,7 +59,7 @@
     is_object_type,
 )
 from .collect_fields import collect_fields, collect_subfields
-from .map_async_iterator import MapAsyncIterator
+from .map_async_iterable import MapAsyncIterable
 from .middleware import MiddlewareManager
 from .values import get_argument_values, get_variable_values
 
@@ -1371,15 +1371,15 @@ async def await_result() -> Any:
             result_or_stream = await awaitable_result_or_stream
             if isinstance(result_or_stream, ExecutionResult):
                 return result_or_stream
-            return MapAsyncIterator(result_or_stream, map_source_to_response)
+            return MapAsyncIterable(result_or_stream, map_source_to_response)
 
         return await_result()
 
     if isinstance(result_or_stream, ExecutionResult):
         return result_or_stream
 
     # Map every source value to a ExecutionResult value as described above.
-    return MapAsyncIterator(
+    return MapAsyncIterable(
         cast(AsyncIterable[Any], result_or_stream), map_source_to_response
     )
 

src/graphql/execution/map_async_iterator.py renamed to src/graphql/execution/map_async_iterable.py

@@ -7,11 +7,11 @@
 from typing import Any, AsyncIterable, Callable, Optional, Set, Type, Union, cast
 
 
-__all__ = ["MapAsyncIterator"]
+__all__ = ["MapAsyncIterable"]
 
 
 # noinspection PyAttributeOutsideInit
-class MapAsyncIterator:
+class MapAsyncIterable:
     """Map an AsyncIterable over a callback function.
 
     Given an AsyncIterable and a callback function, return an AsyncIterator which
@@ -26,7 +26,7 @@ def __init__(self, iterable: AsyncIterable, callback: Callable) -> None:
         self.callback = callback
         self._close_event = Event()
 
-    def __aiter__(self) -> MapAsyncIterator:
+    def __aiter__(self) -> MapAsyncIterable:
         """Get the iterator object."""
         return self
 

tests/execution/test_customize.py

@@ -1,6 +1,6 @@
 from pytest import mark
 
-from graphql.execution import ExecutionContext, MapAsyncIterator, execute, subscribe
+from graphql.execution import ExecutionContext, MapAsyncIterable, execute, subscribe
 from graphql.language import parse
 from graphql.type import GraphQLField, GraphQLObjectType, GraphQLSchema, GraphQLString
 
@@ -73,7 +73,7 @@ async def custom_foo():
             root_value=Root(),
             subscribe_field_resolver=lambda root, _info: root.custom_foo(),
         )
-        assert isinstance(subscription, MapAsyncIterator)
+        assert isinstance(subscription, MapAsyncIterable)
 
         assert await anext(subscription) == (
             {"foo": "FooValue"},
@@ -117,6 +117,6 @@ def resolve_foo(message, _info):
             context_value={},
             execution_context_class=TestExecutionContext,
         )
-        assert isinstance(subscription, MapAsyncIterator)
+        assert isinstance(subscription, MapAsyncIterable)
 
         assert await anext(subscription) == ({"foo": "bar"}, None)