Merge c9307ee into ce941c5

docs/versionhistory.rst

@@ -10,6 +10,7 @@ This library adheres to `Semantic Versioning 2.0 <http://semver.org/>`_.
 - Fixed passing ``total_tokens`` to ``anyio.CapacityLimiter()`` as a keyword argument
   not working on the ``trio`` backend
   (`#515 <https://github.com/agronholm/anyio/issues/515>`_)
+- Fixed inability to start tasks from ``async_generator_asend`` objects on asyncio
 
 **4.2.0**
 

src/anyio/_backends/_asyncio.py

@@ -18,7 +18,7 @@
 )
 from asyncio.base_events import _run_until_complete_cb  # type: ignore[attr-defined]
 from collections import OrderedDict, deque
-from collections.abc import AsyncIterator, Generator, Iterable
+from collections.abc import AsyncIterator, Coroutine, Generator, Iterable
 from concurrent.futures import Future
 from contextlib import suppress
 from contextvars import Context, copy_context
@@ -28,7 +28,6 @@
     CORO_RUNNING,
     CORO_SUSPENDED,
     getcoroutinestate,
-    iscoroutine,
 )
 from io import IOBase
 from os import PathLike
@@ -45,7 +44,6 @@
     Callable,
     Collection,
     ContextManager,
-    Coroutine,
     Mapping,
     Optional,
     Sequence,
@@ -741,7 +739,7 @@ def task_done(_task: asyncio.Task) -> None:
             parent_id = id(self.cancel_scope._host_task)
 
         coro = func(*args, **kwargs)
-        if not iscoroutine(coro):
+        if not isinstance(coro, Coroutine):
             prefix = f"{func.__module__}." if hasattr(func, "__module__") else ""
             raise TypeError(
                 f"Expected {prefix}{func.__qualname__}() to return a coroutine, but "

tests/test_taskgroups.py

@@ -1336,6 +1336,22 @@ async def wait_cancel() -> None:
                 await cancelled.wait()
 
 
+async def test_start_soon_from_asend() -> None:
+    started = False
+
+    async def genfunc() -> AsyncGenerator[None, None]:
+        nonlocal started
+        started = True
+        yield
+
+    generator = genfunc()
+    async with anyio.create_task_group() as task_group:
+        task_group.start_soon(generator.asend, None)
+
+    assert started
+    await generator.aclose()
+
+
 class TestTaskStatusTyping:
     """
     These tests do not do anything at run time, but since the test suite is also checked