Function _drain_stdout

src/mcp/client/stdio.py:228–245

Consumes and discards the server's remaining stdout. Keeps a server flushing buffered output from blocking on a full pipe and missing its chance to exit; shielded, raw bytes, ends when shutdown closes the pipe.

(process: ServerProcess)

async def _drain_stdout(process: ServerProcess) -> None:
    """Consumes and discards the server's remaining stdout.

    Keeps a server flushing buffered output from blocking on a full pipe and
    missing its chance to exit; shielded, raw bytes, ends when shutdown closes
    the pipe.
    """
    assert process.stdout
    with anyio.CancelScope(shield=True):
        with suppress(
            anyio.EndOfStream,
            anyio.ClosedResourceError,
            anyio.BrokenResourceError,
            ConnectionError,
            OSError,
        ):
            while True:
                await process.stdout.receive()


async def _stop_server_process(process: ServerProcess) -> None: