Closes a pipe stream, tolerating one already closed, broken, or contended.
(stream: AsyncResource)
| 268 | |
| 269 | |
| 270 | async def _close_pipe(stream: AsyncResource) -> None: |
| 271 | """Closes a pipe stream, tolerating one already closed, broken, or contended.""" |
| 272 | with suppress(OSError, anyio.BrokenResourceError, anyio.ClosedResourceError): |
| 273 | await stream.aclose() |
| 274 | |
| 275 | |
| 276 | async def _wait_for_process_exit(process: ServerProcess, timeout: float) -> bool: |
no test coverage detected