(self, env: pb.Envelope)
| 252 | return i |
| 253 | |
| 254 | def _write(self, env: pb.Envelope) -> None: |
| 255 | proc = self._proc |
| 256 | if proc is None or proc.stdin is None: |
| 257 | raise CmdopConnectionError("cmdop-core not running") |
| 258 | _write_delimited(proc.stdin, env) |
| 259 | |
| 260 | async def write_answer(self, env: pb.Envelope) -> None: |
| 261 | """Write an ANSWER envelope (pin/confirm) on an open stream's id.""" |
no test coverage detected