Startup

script/local.py

@@ -26,10 +26,7 @@ _load(util.spec_from_file_location("zmq", PYHOME + "/lib/python" + PYVER + "/sit
 import zmq
 #zmq.LINGER = 0
 
-from bsread import source as bs_source
-
-from bsread import Source, PUB, SUB, PUSH, PULL, DEFAULT_DISPATCHER_URL
-
+from bsread import source, Source, PUB, SUB, PUSH, PULL, DEFAULT_DISPATCHER_URL
 from cam_server import CamClient, PipelineClient, ProxyClient, config
 
 from cam_server.utils import get_host_port_from_stream_address

script/test/test_stream_out.py

@@ -29,7 +29,7 @@ def send():
 thread = Thread(target=send)
 thread.start()
 
-with bs_source(host="127.0.0.1", port=OUTPUT_PORT, mode=SUB, receive_timeout = 3000) as stream:
+with source(host="127.0.0.1", port=OUTPUT_PORT, mode=SUB, receive_timeout = 3000) as stream:
     data = stream.receive()
     if not data: 
         raise Exception("Received None message.")