Struct StreamableHttpClient 

pub struct StreamableHttpClient { /* private fields */ }

Streamable HTTP client - MCP-compliant request/response implementation

Implementations

impl StreamableHttpClient

pub fn new( config: StreamableHttpClientConfig, ) -> Result<StreamableHttpClient, TransportError>

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

Authenticate using OAuth 2.1 if configured

pub async fn connect(&mut self) -> Result<String, TransportError>

Connect to the Streamable HTTP server

pub async fn send_notification_internal( &mut self, message: JsonRpcMessage, ) -> Result<(), TransportError>

Send a JSON-RPC notification (fire-and-forget, do not wait for response)

pub async fn get_health(&mut self) -> TransportHealth

Get current connection health

pub async fn is_healthy(&self) -> bool

Check if the connection is healthy

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

Reconnect to the server

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

Reset the client state

pub async fn start_sse_stream(&mut self) -> Result<Response, TransportError>

Start an SSE stream for server-to-client communication

pub async fn resume_sse_stream( &mut self, last_event_id: &str, ) -> Result<Response, TransportError>

Resume an SSE stream from a specific event ID

Trait Implementations

impl Transport for StreamableHttpClient

fn send_message<'life0, 'async_trait>( &'life0 mut self, message: JsonRpcMessage, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, StreamableHttpClient: 'async_trait,

Send a message through the transport

fn receive_message<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<JsonRpcMessage, TransportError>> + Send + 'async_trait>>

where 'life0: 'async_trait, StreamableHttpClient: 'async_trait,

Receive a message from the transport

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

where 'life0: 'async_trait, StreamableHttpClient: 'async_trait,

Close the transport connection gracefully

fn get_state(&self) -> ConnectionState

Get current connection state

fn get_health(&self) -> TransportHealth

Get transport health information

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

where 'life0: 'async_trait, StreamableHttpClient: 'async_trait,

Attempt to reconnect the transport

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

where 'life0: 'async_trait, StreamableHttpClient: 'async_trait,

Reset transport state and clear any cached data

fn is_ready(&self) -> bool

Check if transport is ready for operations

fn shutdown<'life0, 'async_trait>( &'life0 mut self, config: ShutdownConfig, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

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

Initiate graceful shutdown

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

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

Force immediate shutdown