aboutsummaryrefslogtreecommitdiffstats
path: root/termcast_server
diff options
context:
space:
mode:
authorJesse Luehrs <doy@tozt.net>2014-10-20 11:40:16 -0400
committerJesse Luehrs <doy@tozt.net>2014-10-20 11:40:16 -0400
commit6e571d00800cc669f21b18a001cc496f1e90da7d (patch)
tree968d7297082a03f32788e7e7a47dc4f1c03dd0df /termcast_server
parentbdcec99e2971c23095ef991b81a3cf81a5d8832c (diff)
downloadpython-termcast-server-6e571d00800cc669f21b18a001cc496f1e90da7d.tar.gz
python-termcast-server-6e571d00800cc669f21b18a001cc496f1e90da7d.zip
pull this out of the loop
Diffstat (limited to 'termcast_server')
-rw-r--r--termcast_server/pubsub.py6
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)