diff --git a/script/test/test_stream_out.py b/script/test/test_stream_out.py index fc94d24..2dd1b2c 100644 --- a/script/test/test_stream_out.py +++ b/script/test/test_stream_out.py @@ -8,20 +8,21 @@ parameter_queue = queue.Queue() statistics=Namespace() -OUTPUT_PORT = 12005 + viewer.show_stream("tcp://localhost:" + str(OUTPUT_PORT)) pipeline_config = PipelineConfig("test_pipeline", parameters={"camera_name": "simulation", "function":"transparent"}) -def send(): - print ("Startint pipeline on port: ", OUTPUT_PORT) +def send(port): + print ("Startint pipeline on port: ", port) try: - processing_pipeline(stop_event, statistics, parameter_queue, camera_client, pipeline_config, OUTPUT_PORT, MockBackgroundManager()) + processing_pipeline(stop_event, statistics, parameter_queue, camera_client, pipeline_config, port, MockBackgroundManager()) except: traceback.print_exc() -thread = Thread(target=send) +OUTPUT_PORT = 12005 +thread = Thread(target=send, args=(OUTPUT_PORT)) thread.start() with source(host="127.0.0.1", port=OUTPUT_PORT, mode=SUB, receive_timeout = 3000) as stream: