use std::sync::Arc;
use unitree_sdk2_rs::rpc::RpcServer;
#[tokio::main]
async fn main() {
unitree_sdk2_rs::init_dds(0, "", "");
let server = Arc::new(RpcServer::new("rpc_test").expect("创建 RpcServer 失败"));
server.register_handler(1001, |req| format!(r#"{{"echo":"{}"}}"#, req));
server.register_handler(1002, |_| r#"{"result":"ok"}"#.to_string());
eprintln!("RPC 服务端启动中 (rpc_test, api=1001,1002)");
server.clone().start().await;
}