summaryrefslogtreecommitdiff
path: root/tests/_test_async.py
diff options
context:
space:
mode:
Diffstat (limited to 'tests/_test_async.py')
-rw-r--r--tests/_test_async.py43
1 files changed, 0 insertions, 43 deletions
diff --git a/tests/_test_async.py b/tests/_test_async.py
deleted file mode 100644
index 35f3ced..0000000
--- a/tests/_test_async.py
+++ /dev/null
@@ -1,43 +0,0 @@
-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())