The exception is properly caught inthe event system now

This commit is contained in:
Thomas S Hatch 2014-10-02 11:21:35 -06:00
parent a731b97737
commit 4502019340

View File

@ -791,17 +791,11 @@ class LocalClient(object):
if event is None:
event = self.event
while True:
try:
raw = event.get_event_noblock()
if raw and raw.get('tag', '').startswith(jid):
yield raw
else:
yield None
except zmq.ZMQError as ex:
if ex.errno == errno.EAGAIN or ex.errno == errno.EINTR:
yield None
else:
raise
raw = event.get_event_noblock()
if raw and raw.get('tag', '').startswith(jid):
yield raw
else:
yield None
def get_iter_returns(
self,