simplify public_subscribe update

redtrades · Aug 23, 2016 · dedbc62 · dedbc62
1 parent 7e33a0d
commit dedbc62
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/publish_subscribe.py b/publish_subscribe.py
@@ -24,9 +24,8 @@ def unsubscribe(self, msg, subscriber):
 
     def update(self):
         for msg in self.msg_queue:
-            if msg in self.subscribers:
-                for sub in self.subscribers[msg]:
-                    sub.run(msg)
+            for sub in self.subscribers.get(msg, []):
+                sub.run(msg)
         self.msg_queue = []