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

Create a new builder with the given backend configuration

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

Set whether to enable stateful mode

Stateful mode enables session management and server-side push.

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

Set the MCP service identifier

Used for logging and service identification.

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

Set the tool filter configuration

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

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.