Struct StreamableHttpTransport 

pub struct StreamableHttpTransport { /* private fields */ }

Unstable (feature: mcp-transport) — may change or be removed

Streamable HTTP transport.

Implementations

impl StreamableHttpTransport

pub fn new( server_name: &str, endpoint: &str, credential_provider: Option<Arc<dyn McpCredentialProvider>>, timeout_ms: u64, ) -> Result<StreamableHttpTransport, Error>

Build a new transport.

credential_provider is queried for Authorization headers on every request; pass None to disable authentication. timeout_ms == 0 disables the client-side per-request timeout.

Trait Implementations

impl Debug for StreamableHttpTransport

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl McpTransport for StreamableHttpTransport

fn request<'life0, 'life1, 'async_trait>( &'life0 mut self, id: u64, json: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<RawJsonRpcMessage, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, StreamableHttpTransport: 'async_trait,

Send a JSON-RPC request and await the matching response.

fn notify<'life0, 'life1, 'async_trait>( &'life0 mut self, json: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, StreamableHttpTransport: 'async_trait,

Send a JSON-RPC notification (no response expected).

fn set_inbound_handler( &mut self, handler: Box<dyn FnMut(RawJsonRpcMessage) -> Option<Value> + Send + Sync>, )

Install (or replace) the inbound handler. Called by the client before the first request so that any peer-sent message arriving during the handshake is dispatched.

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

where 'life0: 'async_trait, StreamableHttpTransport: 'async_trait,

Close the transport gracefully. Default is a no-op for transports that close on drop.

fn is_connected(&self) -> bool

Whether the transport is currently connected.