diff options
author | Jesse Luehrs <doy@tozt.net> | 2014-10-20 11:40:16 -0400 |
---|---|---|
committer | Jesse Luehrs <doy@tozt.net> | 2014-10-20 11:40:16 -0400 |
commit | 6e571d00800cc669f21b18a001cc496f1e90da7d (patch) | |
tree | 968d7297082a03f32788e7e7a47dc4f1c03dd0df /termcast_server/pubsub.py | |
parent | bdcec99e2971c23095ef991b81a3cf81a5d8832c (diff) | |
download | python-termcast-server-6e571d00800cc669f21b18a001cc496f1e90da7d.tar.gz python-termcast-server-6e571d00800cc669f21b18a001cc496f1e90da7d.zip |
pull this out of the loop
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) |