check for exit condition before transport reconnects

This commit is contained in:
drewhutchison 2014-02-12 15:07:36 -07:00
commit 8f97e73bac

View file

@ -170,13 +170,13 @@ class SocketIO(object):
try: try:
warning_screen = _yield_warning_screen(seconds) warning_screen = _yield_warning_screen(seconds)
for elapsed_time in warning_screen: for elapsed_time in warning_screen:
if self._stop_waiting(for_callbacks):
break
try: try:
try: try:
self._process_events() self._process_events()
except TimeoutError: except TimeoutError:
pass pass
if self._stop_waiting(for_callbacks):
break
self.heartbeat_pacemaker.send(elapsed_time) self.heartbeat_pacemaker.send(elapsed_time)
except ConnectionError as e: except ConnectionError as e:
try: try: