Struct Client

pub struct Client { /* private fields */ }

MCP client state

Implementations

impl Client

pub fn new( sender: UnboundedSender<Message>, receiver: UnboundedReceiver<Message>, ) -> Self

Create a new MCP client

pub async fn initialize( &self, implementation: Implementation, capabilities: Option<ClientCapabilities>, ) -> Result<ServerCapabilities, Error>

Initialize the client

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

Send a request to the server and wait for the response.

This method will block until a response is received from the server. If the server returns an error, it will be propagated as an Error.

pub async fn subscribe(&self, uri: &str) -> Result<(), Error>

pub async fn set_log_level(&self, level: LoggingLevel) -> Result<(), Error>

pub async fn notify( &self, method: &str, params: Option<Value>, ) -> Result<(), Error>

Send a notification to the server

pub async fn capabilities(&self) -> Option<ServerCapabilities>

Get the server capabilities

pub async fn shutdown(&self) -> Result<(), Error>

Close the client connection

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.