Struct StreamableHttpTransport 

pub struct StreamableHttpTransport { /* private fields */ }

Available on crate feature mcp only.

Streamable-HTTP MCP transport.

Construct with StreamableHttpTransport::new for a live connection, or StreamableHttpTransport::with_poster to inject a custom HttpPoster (used by tests).

Implementations

impl StreamableHttpTransport

pub fn new(endpoint: impl Into<String>, auth: McpAuth) -> Result<Arc<Self>>

Create a transport that talks to endpoint over real HTTP.

Errors

Returns an error if the underlying HTTP client cannot be built.

pub fn with_poster(poster: Arc<dyn HttpPoster>, auth: McpAuth) -> Arc<Self>

Create a transport backed by a custom HttpPoster.

This is the seam tests use to script JSON / SSE responses without a network.

pub fn with_header( self, name: impl Into<String>, value: impl Into<String>, ) -> Self

Add a static custom header sent on every request (e.g. a tenant id).

Trait Implementations

impl McpTransport for StreamableHttpTransport

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

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

Send a request and wait for a response.

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

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

Send a notification (fire-and-forget, no response expected).

fn set_protocol_version<'life0, 'life1, 'async_trait>( &'life0 self, version: &'life1 str, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

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

Record the protocol revision negotiated during initialize.

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

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

Close the transport connection.