Struct McpServer 

pub struct McpServer { /* private fields */ }

A running MCP server connection.

A background reader task owns stdout and demultiplexes responses by id into per-request oneshot channels. send_request writes to stdin and then awaits its channel — never read_line directly. So a request timeout (or any cancellation of the caller’s future) only drops a receiver; the reader keeps consuming the stream and discards the now-orphaned response. This makes the transport cancel-safe by construction: there is no read to interrupt mid-line, hence no desync and no poison/recovery dance.

Implementations

impl McpServer

pub async fn start(config: McpServerConfig) -> Result<Self, String>

Start an MCP server and initialize the connection.

pub async fn list_tools(&mut self) -> Result<Vec<McpToolInfo>, String>

Discover tools from this MCP server.

pub async fn call_tool( &mut self, name: &str, arguments: Value, ) -> Result<Value, String>

Call a tool on this MCP server.

pub async fn shutdown(self)

Shut down the MCP server gracefully.

pub fn name(&self) -> &str

Get the server name.

Trait Implementations

impl Drop for McpServer

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.