X-Git-Url: https://git.novaco.in/?p=electrum-server.git;a=blobdiff_plain;f=transports%2Fstratum_tcp.py;fp=transports%2Fstratum_tcp.py;h=6c360862c7a5b3b5c532c343de1f196eb617fa7e;hp=5fb26a552684fe995ce93f4e920f3fea6021ca3c;hb=ca1cec48641795c16f3963d48ddc35416dbbd874;hpb=4082eeacccf3ecec237fe45945af4d9b78352c0e

diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py
index 5fb26a5..6c36086 100644
--- a/transports/stratum_tcp.py
+++ b/transports/stratum_tcp.py
@@ -67,7 +67,10 @@ class TcpClientResponder(threading.Thread):
 
     def run(self):
         while not self.session.stopped():
-            response = self.session.response_queue.get()
+            try:
+                response = self.session.response_queue.get(timeout=10)
+            except queue.Empty:
+                continue
             data = json.dumps(response) + "\n"
             try:
                 while data: