EOF / crash: fail every in-flight call.
(self, exc: Exception)
| 207 | return map_core_error(info.code or "internal", info.message or "") |
| 208 | |
| 209 | def _fail_all(self, exc: Exception) -> None: |
| 210 | """EOF / crash: fail every in-flight call.""" |
| 211 | pending, self._pending = self._pending, {} |
| 212 | for p in pending.values(): |
| 213 | if isinstance(p, _UnaryPending): |
| 214 | if not p.fut.done(): |
| 215 | p.fut.set_exception(exc) |
| 216 | else: |
| 217 | p.queue.put_nowait(exc) |
| 218 | p.queue.put_nowait(_STREAM_END) |
| 219 | |
| 220 | async def aclose(self) -> None: |
| 221 | """Close stdin (graceful drain), reap the child, cancel the read loop.""" |
no outgoing calls
no test coverage detected