]> granicus.if.org Git - python/commitdiff
Issue 24004: Support Awaitables (pep 492) in @asyncio.coroutine decorator
authorYury Selivanov <yselivanov@sprymix.com>
Sun, 31 May 2015 01:02:12 +0000 (21:02 -0400)
committerYury Selivanov <yselivanov@sprymix.com>
Sun, 31 May 2015 01:02:12 +0000 (21:02 -0400)
Lib/asyncio/coroutines.py

index 1e0a70497f89414b18081f6cd9a83a8dbfa3f9bd..4933cf83d2638b85c9e3303352d5a276d4b2194c 100644 (file)
@@ -54,9 +54,10 @@ else:
                                          inspect.CO_COROUTINE)
 
 try:
-    from collections.abc import Coroutine as CoroutineABC
+    from collections.abc import Coroutine as CoroutineABC, \
+                                Awaitable as AwaitableABC
 except ImportError:
-    CoroutineABC = None
+    CoroutineABC = AwaitableABC = None
 
 
 # Check for CPython issue #21209
@@ -192,6 +193,16 @@ def coroutine(func):
             res = func(*args, **kw)
             if isinstance(res, futures.Future) or inspect.isgenerator(res):
                 res = yield from res
+            elif AwaitableABC is not None:
+                # If 'func' returns an Awaitable (new in 3.5) we
+                # want to run it.
+                try:
+                    await_meth = res.__await__
+                except AttributeError:
+                    pass
+                else:
+                    if isinstance(res, AwaitableABC):
+                        res = yield from await_meth()
             return res
 
     if not _DEBUG: