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=a1ac042842838032307c01281b8f787a150c5d62;hp=6c360862c7a5b3b5c532c343de1f196eb617fa7e;hb=f4375ead502d52f5f1e4df8e9b2cc63762326722;hpb=9fd8d787028b7ad349327409cf78658c76f5804d

diff --git a/transports/stratum_tcp.py b/transports/stratum_tcp.py
index 6c36086..a1ac042 100644
--- a/transports/stratum_tcp.py
+++ b/transports/stratum_tcp.py
@@ -94,26 +94,22 @@ class TcpClientRequestor(threading.Thread):
         try:
             self.session.do_handshake()
         except:
+            self.session.stop()
             return
 
         while not self.shared.stopped():
-            if not self.update():
+
+            data = self.receive()
+            if not data:
+                self.session.stop()
                 break
 
+            self.message += data
             self.session.time = time.time()
 
             while self.parse():
                 pass
 
-    def update(self):
-        data = self.receive()
-        if not data:
-            # close_session
-            self.session.stop()
-            return False
-
-        self.message += data
-        return True
 
     def receive(self):
         try: