57e14c56e8* feat(transport): support streamable http server * refactor(transport): add common module for shared transport utilities * perf(tracing): add more log for streamable http session * fix(test): fix port conflict in test with js * fix(transport): fix id generating and session management 1. cancel when deleting 2. use `wrapping` and `saturating` correctly * chore(naming): rename sse server to streamable http server
18 lines
500 B
Rust
18 lines
500 B
Rust
use std::error::Error;
|
|
mod common;
|
|
use common::generic_service::{GenericService, MemoryDataService};
|
|
use rmcp::serve_server;
|
|
|
|
#[tokio::main]
|
|
async fn main() -> Result<(), Box<dyn Error>> {
|
|
let memory_service = MemoryDataService::new("initial data");
|
|
|
|
let generic_service = GenericService::new(memory_service);
|
|
|
|
println!("start server, connect to standard input/output");
|
|
|
|
let io = (tokio::io::stdin(), tokio::io::stdout());
|
|
|
|
serve_server(generic_service, io).await?;
|
|
Ok(())
|
|
}
|