Raise error on connection lost.
This commit is contained in:
parent
c80a2db665
commit
2c1e2ed373
1 changed files with 3 additions and 1 deletions
|
|
@ -237,7 +237,7 @@ class SocketIO(object):
|
||||||
callback, args = find_callback(args, kw)
|
callback, args = find_callback(args, kw)
|
||||||
self._transport.emit(path, event, args, callback)
|
self._transport.emit(path, event, args, callback)
|
||||||
|
|
||||||
def wait(self, seconds=None, for_callbacks=False):
|
def wait(self, seconds=None, for_callbacks=False, raise_error=False):
|
||||||
"""Wait in a loop and process events as defined in the namespaces.
|
"""Wait in a loop and process events as defined in the namespaces.
|
||||||
|
|
||||||
- Omit seconds, i.e. call wait() without arguments, to wait forever.
|
- Omit seconds, i.e. call wait() without arguments, to wait forever.
|
||||||
|
|
@ -254,6 +254,8 @@ class SocketIO(object):
|
||||||
pass
|
pass
|
||||||
next(self._heartbeat_pacemaker)
|
next(self._heartbeat_pacemaker)
|
||||||
except ConnectionError as e:
|
except ConnectionError as e:
|
||||||
|
if raise_error:
|
||||||
|
raise
|
||||||
try:
|
try:
|
||||||
warning = Exception('[connection error] %s' % e)
|
warning = Exception('[connection error] %s' % e)
|
||||||
warning_screen.throw(warning)
|
warning_screen.throw(warning)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue