From 9dad60303acdafb1e918e5614ffcf9d13f80e06d Mon Sep 17 00:00:00 2001 From: Nick Foster Date: Mon, 3 Jun 2013 09:19:49 -0400 Subject: [PATCH] update socks in receive loop --- python/zmq_socket.py | 1 + 1 file changed, 1 insertion(+) diff --git a/python/zmq_socket.py b/python/zmq_socket.py index dcca93b..885f144 100644 --- a/python/zmq_socket.py +++ b/python/zmq_socket.py @@ -93,6 +93,7 @@ class zmq_pubsub_iface(threading.Thread): and socks[self._subsocket] == zmq.POLLIN: [address, msg] = self._subsocket.recv_multipart() self._pubsub[address] = msg + socks = dict(self._poller.poll(timeout=0)) #snooze time.sleep(0.1)