def on_process_exited2(self, returncode):

        if len(self.intermediate_stdout_buffer) > 0:
            self.on_stdout_received(self.intermediate_stdout_buffer + b'\n')
        if len(self.intermediate_stderr_buffer) > 0:
            self.on_stderr_received(self.intermediate_stderr_buffer + b'\n')
Create the stream and start reading from stdin
dataset/ETHPy150Open catkin/catkin_tools/catkin_tools/execution/io.py/IOBufferProtocol.on_process_exited2--crossover with--dataset/ETHPy150Open lbryio/lbry/lbrynet/lbrylive/LBRYStdinUploader.py/LBRYStdinUploader.start_live_stream