diff options
Diffstat (limited to 'pubsub.py')
-rw-r--r-- | pubsub.py | 16 |
1 files changed, 15 insertions, 1 deletions
@@ -10,7 +10,21 @@ class Publisher(object): if who in self.subscribers: self.subscribers.remove(who) - def publish(self, message, *args): + def request_all(self, message, *args): + ret = [] + for subscriber in self.subscribers: + method = "request_" + message + if hasattr(subscriber, method): + ret.append(getattr(subscriber, method)(*args)) + return ret + + def request_one(self, message, *args): + for subscriber in self.subscribers: + method = "request_" + message + if hasattr(subscriber, method): + return getattr(subscriber, method)(*args) + + def notify(self, message, *args): for subscriber in self.subscribers: method = "msg_" + message if hasattr(subscriber, method): |