From 9138d91e125fb4c59ba27446b3f5f532214587ab Mon Sep 17 00:00:00 2001 From: Christian Clauss Date: Thu, 4 Nov 2021 21:22:03 +0100 Subject: use async def instead of asyncio.coroutine --- blinker/_async.py | 4 +--- tests/_test_async.py | 9 +++------ 2 files changed, 4 insertions(+), 9 deletions(-) diff --git a/blinker/_async.py b/blinker/_async.py index 2b530e4..9be304e 100644 --- a/blinker/_async.py +++ b/blinker/_async.py @@ -9,8 +9,7 @@ except AttributeError: schedule = asyncio.ensure_future -@asyncio.coroutine -def _wrap_plain_value(value): +async def _wrap_plain_value(value): """Pass through a coroutine *value* or wrap a plain value.""" if asyncio.iscoroutine(value): value = yield from value @@ -25,4 +24,3 @@ def send_async(self, *sender, **kwargs): send_async.__doc__ = Signal.send_async.__doc__ Signal.send_async = send_async - diff --git a/tests/_test_async.py b/tests/_test_async.py index 35f3ced..fa4c2be 100644 --- a/tests/_test_async.py +++ b/tests/_test_async.py @@ -6,13 +6,11 @@ import blinker def test_send_async(): calls = [] - @asyncio.coroutine - def receiver_a(sender): + async def receiver_a(sender): calls.append(receiver_a) return 'value a' - @asyncio.coroutine - def receiver_b(sender): + async def receiver_b(sender): calls.append(receiver_b) return 'value b' @@ -25,8 +23,7 @@ def test_send_async(): sig.connect(receiver_b) sig.connect(receiver_c) - @asyncio.coroutine - def collect(): + async def collect(): return sig.send_async() loop = asyncio.get_event_loop() -- cgit v1.2.1