multi fetch

Author: golanha

hkube_python_wrapper/communication/streaming/StreamingListener.py

@@ -1,3 +1,4 @@
+import threading
 import time
 from hkube_python_wrapper.util.DaemonThread import DaemonThread
 
@@ -8,15 +9,19 @@ def __init__(self, messageListeners):
         self._working = True
         self._messageListeners = messageListeners
         DaemonThread.__init__(self, "StreamingListener")
-
+    def fetch(self,messageListener):
+        messageListener.fetch()
     def run(self):
         while (self._listeningToMessages):
             messageListeners = self._messageListeners()
             if (not messageListeners):
                 time.sleep(1)  # free some cpu
                 continue
             for listener in messageListeners:
-                listener.fetch()
+                listener.thread = threading.Thread(target=self.fetch, args=[listener])
+                listener.thread.start()
+            for listener in messageListeners:
+                listener.thread.join()
         self._working = False
 
     def stop(self, force=True):