fix: update other examples, comments and readme to take ownership of command

Updated more examples, comments and readme to take command instead of mutable ref.
Also small fix in cargo toml of example to use local path.

Author: humbertoyusta

README.md

@@ -22,17 +22,17 @@ rmcp = { git = "https://github.com/modelcontextprotocol/rust-sdk", branch = "mai
 
 ### Quick start
 
-Start a client in one line:
+Start a client:
 
 ```rust, ignore
 use rmcp::{ServiceExt, transport::TokioChildProcess};
 use tokio::process::Command;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    let client = ().serve(
-        TokioChildProcess::new(Command::new("npx").arg("-y").arg("@modelcontextprotocol/server-everything"))?
-    ).await?;
+    let mut cmd = Command::new("npx");
+    cmd.arg("-y").arg("@modelcontextprotocol/server-everything");
+    let client = ().serve(TokioChildProcess::new(cmd)?).await?;
     Ok(())
 }
 ```
@@ -86,7 +86,7 @@ let server = service.serve(transport).await?;
 Once the server is initialized, you can send requests or notifications:
 
 ```rust, ignore
-// request 
+// request
 let roots = server.list_roots().await?;
 
 // or send notification

crates/rmcp/src/lib.rs

@@ -60,11 +60,9 @@
 //! use tokio::process::Command;
 //!
 //! async fn client() -> Result<()> {
-//!     let service = ()
-//!       .serve(TokioChildProcess::new(
-//!             Command::new("uvx").arg("mcp-server-git"),
-//!         )?)
-//!         .await?;
+//!     let mut cmd = Command::new("uvx");
+//!     cmd.arg("mcp-server-git");
+//!     let service = ().serve(TokioChildProcess::new(cmd)?).await?;
 //!
 //!     // Initialize
 //!     let server_info = service.peer_info();

docs/readme/README.zh-cn.md

@@ -20,9 +20,9 @@ rmcp = { git = "https://github.com/modelcontextprotocol/rust-sdk", branch = "mai
 use rmcp::{ServiceExt, transport::TokioChildProcess};
 use tokio::process::Command;
 
-let client = ().serve(
-    TokioChildProcess::new(Command::new("npx").arg("-y").arg("@modelcontextprotocol/server-everything"))?
-).await?;
+let mut cmd = Command::new("npx");
+cmd.arg("-y").arg("@modelcontextprotocol/server-everything");
+let client = ().serve(TokioChildProcess::new(cmd)?).await?;
 ```
 
 #### 1. 构建传输层
@@ -63,7 +63,7 @@ let server = service.serve(transport).await?;
 一旦服务初始化完成，你可以发送请求或通知：
 
 ```rust, ignore
-// 请求 
+// 请求
 let roots = server.list_roots().await?;
 
 // 或发送通知

examples/clients/src/std_io.rs

@@ -17,12 +17,7 @@ async fn main() -> Result<()> {
     cmd.arg("mcp-server-git");
     let service = ().serve(TokioChildProcess::new(cmd)?).await?;
 
-    // or
-    // serve_client(
-    //     (),
-    //     TokioChildProcess::new(Command::new("uvx").arg("mcp-server-git"))?,
-    // )
-    // .await?;
+    // or serve_client((), TokioChildProcess::new(cmd)?).await?;
 
     // Initialize
     let server_info = service.peer_info();

examples/rig-integration/src/config/mcp.rs

@@ -70,9 +70,7 @@ impl McpServerTransportConfig {
                 envs,
             } => {
                 let mut cmd = tokio::process::Command::new(command);
-                cmd.args(args);
-                cmd.envs(envs);
-                cmd.stderr(Stdio::null());
+                cmd.args(args).envs(envs).stderr(Stdio::null());
                 let transport = rmcp::transport::TokioChildProcess::new(cmd)?;
                 ().serve(transport).await?
             }

examples/simple-chat-client/Cargo.toml

@@ -13,7 +13,7 @@ thiserror = "1.0"
 async-trait = "0.1"
 futures = "0.3"
 toml = "0.8"
-rmcp = { git = "https://github.com/modelcontextprotocol/rust-sdk", features = [
+rmcp = { path = "../../crates/rmcp", features = [
     "client",
     "transport-child-process",
     "transport-sse",

examples/simple-chat-client/src/config.rs

@@ -52,13 +52,12 @@ impl McpServerTransportConfig {
                 args,
                 envs,
             } => {
-                let transport = rmcp::transport::child_process::TokioChildProcess::new(
-                    tokio::process::Command::new(command)
-                        .args(args)
-                        .envs(envs)
-                        .stderr(Stdio::inherit())
-                        .stdout(Stdio::inherit()),
-                )?;
+                let mut cmd = tokio::process::Command::new(command);
+                cmd.args(args)
+                    .envs(envs)
+                    .stderr(Stdio::inherit())
+                    .stdout(Stdio::inherit());
+                let transport = rmcp::transport::child_process::TokioChildProcess::new(cmd)?;
                 ().serve(transport).await?
             }
         };