inherite on loop on Request Handler and CLient

iso8583_web/scripts/forwarder.py

@@ -176,13 +176,16 @@ class RequestHandler(BaseRequestHandler, CommonConnection):
             if self.is_timeout():
                 self.close_because_timeout()
             return
-        # i = 0
+
+        # raw = self.streamer.get(raw)
+        # if not raw:
+        #     return
+        # raw = self.process(raw)
+        # if raw:
+        #     self.send(raw)
+
         while True:
             raw = self.streamer.get(raw)
-            # i += 1
-            # self.log_info(">> RAW {}, {}".format(i, raw))
-            # self.log_info(">> SISA {}, {}".format(i, self.streamer.raw))
-
             if not raw:
                 break
             raw = self.process(raw)
@@ -294,6 +297,32 @@ class Client(BaseClient, CommonConnection):
         except:
             self.log_unknown()
 
+    def on_loop(self):
+        raw = self.receive_raw()
+        if not raw:
+            if self.is_timeout():
+                if not self.conf['listen']:
+                    self.set_connected_time()
+                    return
+
+                self.close_because_timeout()
+            return
+
+        # raw = self.streamer.get(raw)
+        # if not raw:
+        #     return
+        # raw = self.process(raw)
+        # if raw:
+        #     self.send(raw)
+        while True:
+            raw = self.streamer.get(raw)
+            if not raw:
+                break
+            raw = self.process(raw)
+            if raw:
+                self.send(raw)
+            raw = ''
+
 
 def start_client(conf):
     client = Client(conf)