turbomcp 3.0.13

Rust SDK for Model Context Protocol (MCP) with zero-boilerplate macros and WASM support
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

//! TCP Transport Server - Minimal Example
//!
//! Demonstrates TCP transport for network communication.
//!
//! **Run:**
//! ```bash
//! cargo run --example tcp_server --features tcp
//! ```
//!
//! **Connect:**
//! ```bash
//! cargo run --example tcp_client --features tcp
//! ```

#[cfg(feature = "tcp")]
use turbomcp::prelude::*;

#[derive(Clone)]
#[cfg(feature = "tcp")]
struct TcpServer;

#[cfg(feature = "tcp")]
#[turbomcp::server(name = "tcp-demo", version = "1.0.0")]
impl TcpServer {
    #[tool("Echo a message")]
    async fn echo(&self, message: String) -> McpResult<String> {
        Ok(format!("TCP Echo: {}", message))
    }

    #[tool("Add two numbers")]
    async fn add(&self, a: f64, b: f64) -> McpResult<f64> {
        Ok(a + b)
    }
}

#[tokio::main]
#[cfg(feature = "tcp")]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    tracing_subscriber::fmt()
        .with_env_filter("info")
        .with_writer(std::io::stdout)
        .init();

    tracing::info!("🚀 TCP Server listening on 127.0.0.1:8765");

    TcpServer.run_tcp("127.0.0.1:8765").await?;

    Ok(())
}

#[cfg(not(feature = "tcp"))]
fn main() {
    eprintln!(
        "This example requires the 'tcp' feature. Run with: cargo run --example tcp_server --features tcp"
    );
}