Function serve_with 

pub async fn serve_with<T, E, A>(
    transport: T,
    sink: impl Fn(McpCommand) -> bool + Send + 'static,
) -> Result<RunningService<RoleServer, McpServer>, Box<ServerInitializeError>>
where
    T: IntoTransport<RoleServer, E, A>,
    E: Error + Send + Sync + 'static,

Available on crate feature mcp and non-WebAssembly only.

Serve MCP over any transport, handing every command to sink.

The transport is whatever rmcp accepts - stdio, or a pair of streams for a test that wants the server in its own process. The returned service is running; await waiting to serve until the peer leaves.

Errors

Fails when the service cannot complete its handshake over transport.