use async def instead of asyncio.coroutinefeature/send-async

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()