removed print statements and replaced with debug_stream

devices/clients/sst_client.py

@@ -46,8 +46,8 @@ class sst_client(CommClient):
         """
         if not self.connected:
             self.deque = deque(maxlen=1024)
-            self.udp = UDP_Receiver(self.host, self.port, self.deque, self.buffersize, self.timeout)
-            self.sst = SST(self.deque)
+            self.udp = UDP_Receiver(self.host, self.port, self.deque, self.streams, self.buffersize, self.timeout)
+            self.sst = SST(self.deque, self.streams)
             return super().connect()
 
     def disconnect(self):
@@ -88,7 +88,6 @@ class sst_client(CommClient):
 
 
         def read_function():
-            print([self.sst.parameters[SST_param]])
             return [self.sst.parameters[SST_param]]
 
         def write_function(value):
@@ -104,8 +103,9 @@ class UDP_Receiver(Thread):
     This class provides a small wrapper for the OPC ua read/write functions in order to better organise the code
     """
 
-    def __init__(self, host, port, deque, buffersize=9000, timeout=0.1):
+    def __init__(self, host, port, deque, streams, buffersize=9000, timeout=0.1):
 
+        self.streams = streams
         self.deque = deque
         self.host = host
         self.port = port
@@ -124,7 +124,7 @@ class UDP_Receiver(Thread):
 
     def run(self):
         # all variables are manually defined and are updated each time
-        print("starting UDP thread with port {} and host {}".format(self.port, self.host))
+        self.streams.debug_stream("starting UDP thread with port {} and host {}".format(self.port, self.host))
 
         while self.stream_on:
             try:
@@ -146,8 +146,9 @@ class UDP_Receiver(Thread):
 
 
 class SST(Thread):
-    def __init__(self, deque):
+    def __init__(self, deque, streams):
 
+        self.streams = streams
         self.deque = deque
         self.last_packet = None
 
@@ -160,7 +161,7 @@ class SST(Thread):
         self.start()
 
     def run(self):
-        print("starting SST thread")
+        self.streams.debug_stream("starting SST thread")
 
         while True: