Struct StreamableHttpClientTransportConfig 

#[non_exhaustive]
pub struct StreamableHttpClientTransportConfig {
    pub uri: Arc<str>,
    pub retry_config: Arc<dyn SseRetryPolicy>,
    pub channel_buffer_capacity: usize,
    pub allow_stateless: bool,
    pub auth_header: Option<String>,
    pub custom_headers: HashMap<HeaderName, HeaderValue>,
    pub max_sse_event_size: usize,
    pub reinit_on_expired_session: bool,
}

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

uri: Arc<str>

retry_config: Arc<dyn SseRetryPolicy>

channel_buffer_capacity: usize

allow_stateless: bool

if true, the transport will not require a session to be established

auth_header: Option<String>

The value to send in the authorization header

custom_headers: HashMap<HeaderName, HeaderValue>

Custom HTTP headers to include with every request

max_sse_event_size: usize

Maximum raw size of one SSE event accepted from the server.

The built-in reqwest and Unix socket clients enforce this value. Custom StreamableHttpClient implementations must override the corresponding *_with_max_sse_event_size methods to enforce it.

reinit_on_expired_session: bool

Enables transparent recovery when the server reports an expired session (HTTP 404).

When enabled, the transport performs one automatic recovery attempt:

1. Replays the original initialize handshake to create a new session.
2. Re-establishes streaming state for that session.
3. Retries the in-flight request that failed with SessionExpired.

This recovery is best-effort and bounded to a single attempt. If recovery fails, the original failure path is preserved and the error is returned to the caller.

Implementations

impl StreamableHttpClientTransportConfig

pub fn with_uri(uri: impl Into<Arc<str>>) -> StreamableHttpClientTransportConfig

pub fn auth_header<T>(self, value: T) -> StreamableHttpClientTransportConfig

where T: Into<String>,

Set the authorization header to send with requests

Arguments

• value - A bearer token without the Bearer prefix

pub fn custom_headers( self, custom_headers: HashMap<HeaderName, HeaderValue>, ) -> StreamableHttpClientTransportConfig

Set custom HTTP headers to include with every request

Arguments

• custom_headers - A HashMap of header names to header values

Example

use std::collections::HashMap;
use http::{HeaderName, HeaderValue};
use rmcp::transport::streamable_http_client::StreamableHttpClientTransportConfig;

let mut headers = HashMap::new();
headers.insert(
    HeaderName::from_static("x-custom-header"),
    HeaderValue::from_static("custom-value")
);

let config = StreamableHttpClientTransportConfig::with_uri("http://localhost:8000")
    .custom_headers(headers);

pub fn max_sse_event_size( self, bytes: usize, ) -> StreamableHttpClientTransportConfig

Set the maximum raw size of one SSE event accepted from the server.

pub fn reinit_on_expired_session( self, enable: bool, ) -> StreamableHttpClientTransportConfig

Set whether the transport should attempt transparent re-initialization on session expiration See Self::reinit_on_expired_session for details.

Example

use rmcp::transport::streamable_http_client::StreamableHttpClientTransportConfig;
let config = StreamableHttpClientTransportConfig::with_uri("http://localhost:8000")
    .reinit_on_expired_session(true);

Trait Implementations

impl Clone for StreamableHttpClientTransportConfig

fn clone(&self) -> StreamableHttpClientTransportConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamableHttpClientTransportConfig

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

Formats the value using the given formatter.

impl Default for StreamableHttpClientTransportConfig

fn default() -> StreamableHttpClientTransportConfig

Returns the “default value” for a type.