run_stream_server

Function run_stream_server 

Source
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};

let handler = ProxyHandler::new_disconnected(
    Default::default(),
    "test-mcp".to_string(),
);

run_stream_server(handler, "127.0.0.1:3000", false).await?;