Struct Protocol

pub struct Protocol<T: Transport> { /* private fields */ }

The main protocol implementation for handling MCP messages

Manages bidirectional communication between client and server, handling requests, notifications, and their respective responses.

Implementations

impl<T: Transport> Protocol<T>

pub fn builder(transport: T) -> ProtocolBuilder<T>

Creates a new protocol builder with the given transport

Arguments

• transport - The transport layer to use for communication

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

Sends a notification to the remote endpoint

Arguments

• method - The notification method name
• params - Optional parameters for the notification

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

Send a JSON-RPC request to the server

Arguments

• method - The name of the method to call
• params - Optional parameters for the method
• options - Request options like timeout

Returns

The JSON-RPC response from the server

pub async fn listen(&self) -> Result<(), TransportError>

Listen for and handle incoming JSON-RPC messages

This method runs indefinitely, processing incoming messages and routing them to the appropriate handlers.

Trait Implementations

impl<T: Clone + Transport> Clone for Protocol<T>

fn clone(&self) -> Protocol<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.