Write an ANSWER envelope (pin/confirm) on an open stream's id.
(self, env: pb.Envelope)
| 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.""" |
| 262 | await self._ensure_started() |
| 263 | self._write(env) |
| 264 | if self._proc is not None and self._proc.stdin is not None: |
| 265 | await self._proc.stdin.drain() |
| 266 | |
| 267 | # -- call entry points (used by generated resources) ------------------- |
| 268 |
no test coverage detected