update socks in receive loop

2013-06-03 09:19:49 -04:00
parent 4fe2334b28
commit 9dad60303a
1 changed files with 1 additions and 0 deletions
@@ -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)