(self)
| 6 | |
| 7 | class ProcessHandler: |
| 8 | def __init__(self): |
| 9 | self._process = None |
| 10 | self._output_queue = AsyncQueue() # Use asyncio.Queue |
| 11 | self._is_running = False |
| 12 | self._is_starting = False |
| 13 | self._stream_tasks = [] # Store stream tasks |
| 14 | |
| 15 | async def run(self, command: list, cwd: str): |
| 16 | if self._is_running or self._is_starting: |
nothing calls this directly
no outgoing calls
no test coverage detected