Method get_stream

src/process_handler.py:81–89

(self)

        return self._output_queue  # return the queue for external subscription

    async def get_stream(self):
      while True:
            try:
                output = await asyncio.wait_for(self._output_queue.get(),timeout=0.1)
                yield output
            except asyncio.TimeoutError:
               if not self._is_running and self._process is None:
                    break #close if process is not running
               continue