Struct McpClient 

pub struct McpClient {
    pub progress_dispatcher: ProgressDispatcher,
    /* private fields */
}

Fields

progress_dispatcher: ProgressDispatcher

Implementations

impl McpClient

pub fn new( client_info: ClientInfo, server_name: String, event_sender: Sender<McpClientEvent>, roots: Arc<RwLock<Vec<Root>>>, ) -> Self

pub fn server_name(&self) -> &str

pub async fn dispatch_elicitation( &self, request: CreateElicitationRequestParams, ) -> CreateElicitationResult

Dispatch an elicitation request through the shared event channel.

Used by both the create_elicitation handler and the -32042 URL_ELICITATION_REQUIRED error path to ensure the same user-facing flow.

pub async fn forward_url_elicitation_complete(&self, elicitation_id: String)

Forward a URL elicitation completion through the shared event channel.

Split out from on_url_elicitation_notification_complete so it can be tested without constructing a NotificationContext.

Trait Implementations

impl ClientHandler for McpClient

fn get_info(&self) -> ClientInfo

async fn on_progress( &self, params: ProgressNotificationParam, _context: NotificationContext<RoleClient>, )

async fn create_elicitation( &self, request: CreateElicitationRequestParams, _context: RequestContext<RoleClient>, ) -> Result<CreateElicitationResult, ErrorData>

Handle an elicitation request from a server asking for user input.

async fn on_url_elicitation_notification_complete( &self, params: ElicitationResponseNotificationParam, _context: NotificationContext<RoleClient>, )

async fn list_roots( &self, _context: RequestContext<RoleClient>, ) -> Result<ListRootsResult, ErrorData>

fn ping( &self, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn create_message( &self, params: CreateMessageRequestParams, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<CreateMessageResult, ErrorData>> + MaybeSendFuture

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleClient>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, params: CancelledNotificationParam, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_logging_message( &self, params: LoggingMessageNotificationParam, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_resource_updated( &self, params: ResourceUpdatedNotificationParam, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_resource_list_changed( &self, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_tool_list_changed( &self, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_prompt_list_changed( &self, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleClient>, ) -> impl Future<Output = ()> + MaybeSendFuture