diff options
author | Yury Selivanov <yselivanov@sprymix.com> | 2015-05-31 01:02:12 (GMT) |
---|---|---|
committer | Yury Selivanov <yselivanov@sprymix.com> | 2015-05-31 01:02:12 (GMT) |
commit | a316085192382e56c8322da395231e24c6dbdc5b (patch) | |
tree | d2be47eb67d67cb1ed1b227817b847a119af8ae3 /Lib | |
parent | 03395687532243d3aae9b7a56a344080dcb959a4 (diff) | |
download | cpython-a316085192382e56c8322da395231e24c6dbdc5b.zip cpython-a316085192382e56c8322da395231e24c6dbdc5b.tar.gz cpython-a316085192382e56c8322da395231e24c6dbdc5b.tar.bz2 |
Issue 24004: Support Awaitables (pep 492) in @asyncio.coroutine decorator
Diffstat (limited to 'Lib')
-rw-r--r-- | Lib/asyncio/coroutines.py | 15 |
1 files changed, 13 insertions, 2 deletions
diff --git a/Lib/asyncio/coroutines.py b/Lib/asyncio/coroutines.py index 1e0a704..4933cf8 100644 --- a/Lib/asyncio/coroutines.py +++ b/Lib/asyncio/coroutines.py @@ -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: |