Struct HttpTransport 

pub struct HttpTransport { /* private fields */ }

Communicates with an MCP server via HTTP POST (JSON-RPC over HTTP).

Implementations

impl HttpTransport

pub fn new(url: &str) -> Result<Self, McpError>

Create a new HTTP transport with the default request timeout.

pub fn new_with_timeout( url: &str, request_timeout: Duration, ) -> Result<Self, McpError>

Create a new HTTP transport with a custom request timeout.

The timeout is enforced by the outer tokio::time::timeout in send(), which hard-cancels the inner future (connect + read + JSON parse) on expiry. We deliberately do not set reqwest::Client::builder().timeout(d) to avoid a race between reqwest’s internal timer and the outer tokio timer — having both fire at the same duration produces a non-deterministic error classification.

Trait Implementations

impl McpTransport for HttpTransport

fn send<'life0, 'async_trait>( &'life0 self, request: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcResponse, McpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a JSON-RPC request and receive the response.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), McpError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the transport (kill child process, close HTTP connections, etc.).