From c0783810f02739a276f38ef345c723038f30753f Mon Sep 17 00:00:00 2001 From: vic Date: Sun, 5 Nov 2023 15:58:25 -0500 Subject: [PATCH] Halt threads if shutdown --- nostr/relay.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/nostr/relay.py b/nostr/relay.py index 9911237..96c66dd 100644 --- a/nostr/relay.py +++ b/nostr/relay.py @@ -47,6 +47,7 @@ class Relay: self.queue = Queue() def connect(self, ssl_options: dict = None, proxy: dict = None): + if self.shutdown: return self.ws = WebSocketApp( self.url, on_open=self._on_open, @@ -98,10 +99,12 @@ class Relay: message = self.queue.get(timeout=1) self.ws.send(message) self.num_sent_events += 1 - except: + except Exception as e: if shutdown(): break else: + if shutdown(): + break time.sleep(0.1) def add_subscription(self, id, filters: Filters):