Merge contribution from leth
This commit is contained in:
commit
b394c8a55a
1 changed files with 13 additions and 16 deletions
|
|
@ -175,7 +175,6 @@ class SocketIO(object):
|
||||||
"""
|
"""
|
||||||
warning_screen = _yield_warning_screen(seconds)
|
warning_screen = _yield_warning_screen(seconds)
|
||||||
for elapsed_time in warning_screen:
|
for elapsed_time in warning_screen:
|
||||||
try:
|
|
||||||
if self._stop_waiting(for_callbacks):
|
if self._stop_waiting(for_callbacks):
|
||||||
break
|
break
|
||||||
try:
|
try:
|
||||||
|
|
@ -191,8 +190,6 @@ class SocketIO(object):
|
||||||
except StopIteration:
|
except StopIteration:
|
||||||
_log.warn(warning)
|
_log.warn(warning)
|
||||||
self.disconnect()
|
self.disconnect()
|
||||||
except KeyboardInterrupt:
|
|
||||||
pass
|
|
||||||
|
|
||||||
def _process_events(self):
|
def _process_events(self):
|
||||||
for packet in self._transport.recv_packet():
|
for packet in self._transport.recv_packet():
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue