From d841e82241a209573a1da638aa64921c7e65b811 Mon Sep 17 00:00:00 2001 From: jason kirtland 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