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 builder(endpoint: impl Into<String>, auth: McpAuth) -> Result<Self>

Create an un-wrapped transport over real HTTP for further builder-style configuration (e.g. StreamableHttpTransport::with_header).

Wrap the result in Arc before handing it to McpClient::new:

use std::sync::Arc;
use agent_sdk::mcp::{McpAuth, StreamableHttpTransport};

let transport = Arc::new(
    StreamableHttpTransport::builder("https://example.com/mcp", McpAuth::None)?
        .with_header("X-Tenant-Id", "acme"),
);

Errors

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

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

Create an un-wrapped transport backed by a custom HttpPoster, for further builder-style configuration before wrapping in Arc.

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).

Call this on an un-wrapped transport from StreamableHttpTransport::builder (or StreamableHttpTransport::with_poster_owned) before wrapping it in Arc.

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.