Struct StreamingHttpClientTransport 

pub struct StreamingHttpClientTransport { /* private fields */ }

Streaming HTTP client transport with advanced features

Implementations

impl StreamingHttpClientTransport

pub async fn new<S: AsRef<str>>(base_url: S) -> McpResult<Self>

Create streaming HTTP transport with default configuration

pub async fn with_config<S: AsRef<str>>( base_url: S, config: StreamingConfig, ) -> McpResult<Self>

Create streaming HTTP transport with custom configuration

pub async fn get_stats(&self) -> TransportStats

pub async fn get_analysis_stats(&self) -> AnalysisStats

pub async fn register_push_handler<F>(&mut self, path: String, handler: F)

where F: Fn(PushPromise) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send>> + Send + Sync + 'static,

Register a server push handler for specific paths

pub async fn get_http2_stats(&self) -> (usize, u64, u64)

Get HTTP/2 stream statistics

pub async fn send_multiplexed_requests( &mut self, requests: Vec<JsonRpcRequest>, ) -> McpResult<Vec<JsonRpcResponse>>

Send multiplexed HTTP/2 requests for improved performance

Trait Implementations

impl Transport for StreamingHttpClientTransport

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

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

Send a JSON-RPC request and wait for a response

fn send_notification<'life0, 'async_trait>( &'life0 mut self, notification: JsonRpcNotification, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Send a JSON-RPC notification (no response expected)

fn receive_notification<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcNotification>>> + Send + 'async_trait>>

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

Receive a notification from the server (non-blocking)

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

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

Close the transport connection

fn open_subscription<'life0, 'async_trait>( &'life0 mut self, _request: JsonRpcRequest, ) -> Pin<Box<dyn Future<Output = McpResult<ClientSubscription>> + Send + 'async_trait>>

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

Open a modern long-lived subscription stream.

fn cancel_subscription<'life0, 'life1, 'async_trait>( &'life0 mut self, _request_id: &'life1 Value, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Cancel an open subscription. HTTP implementations close the response stream; STDIO implementations send notifications/cancelled.

fn handle_incoming_request<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = McpResult<Option<JsonRpcRequest>>> + Send + 'async_trait>>

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

Handle incoming server request (for bidirectional communication)

fn send_response<'life0, 'async_trait>( &'life0 mut self, _response: JsonRpcResponse, ) -> Pin<Box<dyn Future<Output = McpResult<()>> + Send + 'async_trait>>

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

Send response to server request (for bidirectional communication)

fn is_connected(&self) -> bool

Check if the transport is connected

fn connection_info(&self) -> String

Get connection information for debugging