Method _ensure_started

python/src/cmdop/_transport.py:103–129

(self)

                self._binary_path,
                "--stdio",
                stdin=asyncio.subprocess.PIPE,
                stdout=asyncio.subprocess.PIPE,
                stderr=asyncio.subprocess.PIPE,
                env=env,
            )
            self._reader_task = asyncio.create_task(self._read_loop())
            self._stderr_task = asyncio.create_task(self._drain_stderr())

    async def _drain_stderr(self) -> None:
        assert self._process is not None and self._process.stderr is not None
        while await self._process.stderr.readline():
            pass

    async def _read_loop(self) -> None:
        assert self._process is not None and self._process.stdout is not None
        try:
            while True:
                envelope = pb.Envelope.FromString(
                    await _read_delimited(self._process.stdout)
                )
                self._dispatch(envelope)
        except asyncio.IncompleteReadError:
            self._fail_all(CmdopConnectionError("cmdop-core exited", code="transport"))
        except asyncio.CancelledError:
            raise
        except Exception as exc:  # noqa: BLE001
            self._fail_all(
                CmdopConnectionError(f"core read failed: {exc}", code="transport")
            )