Struct McpClient 

pub struct McpClient { /* private fields */ }

A connected client. Cheap to clone, and clones share the connection.

Implementations

impl McpClient

pub async fn connect( options: ClientOptions, transport: Transport, ) -> Result<McpClient, McpError>

Opens transport and performs the initialize handshake.

pub async fn connect_with_stderr( options: ClientOptions, transport: Transport, ) -> Result<McpClient, Box<(McpError, Option<String>)>>

McpClient::connect, failing with a stdio server’s stderr too, as pi reads it for every failed connection.

pub fn same(&self, other: &McpClient) -> bool

Whether other is a clone of this client.

pub fn is_connected(&self) -> bool

Whether the connection is open.

pub fn server(&self) -> Option<ServerInfo>

What the server said in initialize.

pub fn stderr(&self) -> Option<String>

The end of a stdio server’s stderr.

pub fn on_notification( &self, method: &str, listener: impl Fn(&Value) + Send + Sync + 'static, )

Calls listener with the parameters of every method notification.

pub fn on_close(&self, listener: impl Fn() + Send + Sync + 'static)

Calls listener once when the connection closes, for any reason.

pub async fn request( &self, method: &str, params: Option<Value>, options: RequestOptions, ) -> Result<Value, McpError>

Sends a request and waits for its result.

pub async fn list_tools( &self, options: RequestOptions, ) -> Result<Vec<Tool>, McpError>

Every tool, following pagination.

pub async fn list_resources( &self, kind: ResourceKind, options: RequestOptions, ) -> Result<Vec<Value>, McpError>

Every resource or resource template, following pagination.

pub async fn list_resources_page( &self, kind: ResourceKind, cursor: Option<String>, options: RequestOptions, ) -> Result<(Vec<Value>, Option<String>), McpError>

One page of resources or resource templates from cursor, and the next cursor.

pub async fn read_resource( &self, uri: &str, options: RequestOptions, ) -> Result<Value, McpError>

Reads one resource.

pub async fn call_tool( &self, name: &str, arguments: Value, options: RequestOptions, ) -> Result<Value, McpError>

Calls a tool. A result without content gets an empty one, as the SDKs default it.

pub async fn close(&self)

Closes the connection. Requests in flight fail.

Trait Implementations

impl Clone for McpClient

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.