From dedbc62c246f50181fa688f7b7ba9150782287a4 Mon Sep 17 00:00:00 2001 From: Xuefeng Zhu Date: Tue, 23 Aug 2016 11:09:36 -0500 Subject: [PATCH] simplify public_subscribe update --- publish_subscribe.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/publish_subscribe.py b/publish_subscribe.py index 6c03c392..c748c1a4 100644 --- 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 = []