Method stream_output

src/process_handler.py:34–44

(stream, prefix)

            self._is_starting = False

            async def stream_output(stream, prefix):
                 while True:
                     line = await stream.readline()
                     if line:
                         message = f"{prefix}{line.decode().strip()}"
                         print(message,flush=True) #flush output immediately
                         if prefix == "STDOUT: ": # only add stdout
                            await self._output_queue.put(message)
                            
                     else:
                         break

            # Create tasks and store them to cancel later
            stdout_task = asyncio.create_task(stream_output(self._process.stdout, "STDOUT: "))