improve wait time before reconnecting
This commit is contained in:
@@ -183,13 +183,13 @@ class GotifyClient(GotifySession):
|
|||||||
self.listener.start()
|
self.listener.start()
|
||||||
|
|
||||||
def opened_callback(self, user_callback: Callable[[], None] = None):
|
def opened_callback(self, user_callback: Callable[[], None] = None):
|
||||||
|
self.reset_wait_time()
|
||||||
if user_callback:
|
if user_callback:
|
||||||
user_callback()
|
user_callback()
|
||||||
|
|
||||||
def reconnect(self):
|
def reconnect(self):
|
||||||
if not self.is_listening():
|
if not self.is_listening():
|
||||||
self.listener.start()
|
self.listener.start()
|
||||||
self.reset_wait_time()
|
|
||||||
|
|
||||||
def stop(self, reset_wait: bool = False):
|
def stop(self, reset_wait: bool = False):
|
||||||
if reset_wait:
|
if reset_wait:
|
||||||
|
|||||||
@@ -50,6 +50,7 @@ class Listener(QtCore.QThread):
|
|||||||
self.new_message.emit(GotifyMessageModel(json.loads(message)))
|
self.new_message.emit(GotifyMessageModel(json.loads(message)))
|
||||||
|
|
||||||
def _on_error(self, ws: websocket.WebSocketApp, error: Exception):
|
def _on_error(self, ws: websocket.WebSocketApp, error: Exception):
|
||||||
|
logger.error(f"websocket error: {error}")
|
||||||
self.error.emit(error)
|
self.error.emit(error)
|
||||||
|
|
||||||
def _on_open(self, ws: websocket.WebSocketApp):
|
def _on_open(self, ws: websocket.WebSocketApp):
|
||||||
|
|||||||
Reference in New Issue
Block a user