diff options
Diffstat (limited to 'termcast_server/pubsub.py')
| -rw-r--r-- | termcast_server/pubsub.py | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/termcast_server/pubsub.py b/termcast_server/pubsub.py index b5faf22..7578b09 100644 --- a/termcast_server/pubsub.py +++ b/termcast_server/pubsub.py @@ -11,21 +11,21 @@ class Publisher(object): self.subscribers.remove(who) def request_all(self, message, *args): + method = "request_" + message 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): + method = "request_" + message for subscriber in self.subscribers: - method = "request_" + message if hasattr(subscriber, method): return getattr(subscriber, method)(*args) def notify(self, message, *args): + method = "msg_" + message for subscriber in self.subscribers: - method = "msg_" + message if hasattr(subscriber, method): getattr(subscriber, method)(*args) |