diff options
author | Youri Ackx <youri@sugoi.be> | 2021-01-29 14:36:38 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-01-29 14:36:38 +0100 |
commit | b5e9f0629200d2b2f62e13e595b802948bb4fefb (patch) | |
tree | 4741857fe53c5500487894c2e3c9ff9c4ee2ce3b /blinker/base.py | |
parent | 904d8d3803e84257c08526e9047474215aa1c976 (diff) | |
parent | c7b83a18a54efa9e08a9446e2d16956ee5fe353b (diff) | |
download | blinker-b5e9f0629200d2b2f62e13e595b802948bb4fefb.tar.gz |
Merge pull request #18 from jek/feature/send-asyncmaster
Adds Signal.send_async for asyncio
Author: @jek
Diffstat (limited to 'blinker/base.py')
-rw-r--r-- | blinker/base.py | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/blinker/base.py b/blinker/base.py index b68d8db..a2f22aa 100644 --- a/blinker/base.py +++ b/blinker/base.py @@ -271,6 +271,17 @@ class Signal(object): return [(receiver, receiver(sender, **kwargs)) for receiver in self.receivers_for(sender)] + def send_async(self, *sender, **kwargs): + """Send and collect results from connected functions and coroutines. + + As `Signal.send`, but also schedules any coroutines connected to the + signal, and uniformly presents all receiver return values as futures, + even if one or more receivers are regular functions. + + Available only if asyncio and `yield from` are present. + """ + raise NotImplementedError("asyncio support unavailable") + def has_receivers_for(self, sender): """True if there is probably a receiver for *sender*. |