Struct StreamServerBuilder 

pub struct StreamServerBuilder { /* private fields */ }

Builder for creating Streamable HTTP MCP servers

Provides a fluent API for configuring and building MCP proxy servers.

Example

use mcp_streamable_proxy::server_builder::{StreamServerBuilder, BackendConfig};

// Create a server with stdio backend
let (router, ct) = StreamServerBuilder::new(BackendConfig::Stdio {
    command: "npx".into(),
    args: Some(vec!["-y".into(), "@modelcontextprotocol/server-filesystem".into()]),
    env: None,
})
.mcp_id("my-server")
.stateful(false)
.build()
.await?;

Implementations

impl StreamServerBuilder

pub fn new(backend: BackendConfig) -> Self

Create a new builder with the given backend configuration

pub fn stateful(self, enabled: bool) -> Self

Set whether to enable stateful mode

Stateful mode enables session management and server-side push.

pub fn mcp_id(self, id: impl Into<String>) -> Self

Set the MCP service identifier

Used for logging and service identification.

pub fn tool_filter(self, filter: ToolFilter) -> Self

Set the tool filter configuration

pub async fn build(self) -> Result<(Router, CancellationToken, ProxyHandler)>

Build the server and return an axum Router, CancellationToken, and ProxyHandler

The router can be merged with other axum routers or served directly. The CancellationToken can be used to gracefully shut down the service. The ProxyHandler can be used for status checks and management.