jyapayne/socketIO-client
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge branch 'leth-patch-1'

Browse source
This commit is contained in:
Roy Hyunjin Han 2015-01-09 20:23:35 +09:00
commit 88bf4c0bcc
1 changed files with 13 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

29
socketIO_client/__init__.py
View file

@ -175,24 +175,21 @@ class SocketIO(object):
"""
warning_screen = _yield_warning_screen(seconds)
for elapsed_time in warning_screen:
if self._stop_waiting(for_callbacks):
break
try:
if self._stop_waiting(for_callbacks):
break
try:
try:
self._process_events()
except TimeoutError:
pass
self.heartbeat_pacemaker.send(elapsed_time)
except ConnectionError as e:
try:
warning = Exception('[connection error] %s' % e)
warning_screen.throw(warning)
except StopIteration:
_log.warn(warning)
self.disconnect()
except KeyboardInterrupt:
pass
self._process_events()
except TimeoutError:
pass
self.heartbeat_pacemaker.send(elapsed_time)
except ConnectionError as e:
try:
warning = Exception('[connection error] %s' % e)
warning_screen.throw(warning)
except StopIteration:
_log.warn(warning)
self.disconnect()
def _process_events(self):
for packet in self._transport.recv_packet():