()
| 71 | |
| 72 | |
| 73 | def _make_transport() -> tuple[Transport, FakeProc]: |
| 74 | cfg = ClientConfig.resolve(token="t", base_url="https://x") |
| 75 | t = Transport(cfg, "/nonexistent/cmdop-core") |
| 76 | proc = FakeProc() |
| 77 | # Wire the fake proc in without spawning. |
| 78 | t._proc = proc # type: ignore[assignment] |
| 79 | t._reader_task = asyncio.get_running_loop().create_task(t._read_loop()) |
| 80 | return t, proc |
| 81 | |
| 82 | |
| 83 | def _feed(proc: FakeProc, env: pb.Envelope) -> None: |
no test coverage detected