pub async fn run_stream_server(
proxy_handler: ProxyHandler,
bind_addr: &str,
quiet: bool,
) -> Result<()>Expand description
Run Streamable HTTP server with ProxyAwareSessionManager
§Features
- Stateful Mode:
stateful_mode: true支持 session 管理和服务端推送 - Version Control: 自动检测后端重连,使旧 session 失效
- Hot Swap: 支持后端连接热替换
§Arguments
proxy_handler- ProxyHandler 实例(包含后端版本控制)bind_addr- 绑定地址,例如 “127.0.0.1:3000”quiet- 静默模式,不输出启动信息
§Example
use mcp_streamable_proxy::{ProxyHandler, run_stream_server};
use mcp_common::ToolFilter;
let handler = ProxyHandler::new_disconnected(
"test-mcp".to_string(),
ToolFilter::default(),
Default::default(),
);
run_stream_server(handler, "127.0.0.1:3000", false).await?;