From d841e82241a209573a1da638aa64921c7e65b811 Mon Sep 17 00:00:00 2001
From: jason kirtland <jek@discorporate.us>
Date: Thu, 23 Jul 2015 17:18:39 +0200
Subject: Adds Signal.send_async for asyncio

---
 tests/_test_async.py | 43 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 43 insertions(+)
 create mode 100644 tests/_test_async.py

(limited to 'tests/_test_async.py')

diff --git a/tests/_test_async.py b/tests/_test_async.py
new file mode 100644
index 0000000..35f3ced
--- /dev/null
+++ b/tests/_test_async.py
@@ -0,0 +1,43 @@
+import asyncio
+
+import blinker
+
+
+def test_send_async():
+    calls = []
+
+    @asyncio.coroutine
+    def receiver_a(sender):
+        calls.append(receiver_a)
+        return 'value a'
+
+    @asyncio.coroutine
+    def receiver_b(sender):
+        calls.append(receiver_b)
+        return 'value b'
+
+    def receiver_c(sender):
+        calls.append(receiver_c)
+        return 'value c'
+
+    sig = blinker.Signal()
+    sig.connect(receiver_a)
+    sig.connect(receiver_b)
+    sig.connect(receiver_c)
+
+    @asyncio.coroutine
+    def collect():
+        return sig.send_async()
+
+    loop = asyncio.get_event_loop()
+    results = loop.run_until_complete(collect())
+
+    expected = {
+        receiver_a: 'value a',
+        receiver_b: 'value b',
+        receiver_c: 'value c',
+        }
+
+    assert set(calls) == set(expected.keys())
+    collected_results = {v.result() for r, v in results}
+    assert collected_results == set(expected.values())
-- 
cgit v1.2.1