Merge branch 'main' into acitx-web-example

Author: xring

crates/mcp-macros/Cargo.toml

@@ -2,6 +2,8 @@
 name = "mcp-macros"
 version.workspace = true
 edition.workspace = true
+license.workspace = true
+repository.workspace = true
 
 [lib]
 proc-macro = true

crates/mcp-server/src/lib.rs

@@ -105,13 +105,17 @@ where
     R: AsyncRead + Unpin,
     W: AsyncWrite + Unpin,
 {
-    pub async fn write_message(&mut self, msg: JsonRpcMessage) -> Result<(), std::io::Error> {
+    pub async fn write_message(
+        self: &mut Pin<&mut Self>,
+        msg: JsonRpcMessage,
+    ) -> Result<(), std::io::Error> {
         let json = serde_json::to_string(&msg)?;
-        Pin::new(&mut self.writer)
-            .write_all(json.as_bytes())
-            .await?;
-        Pin::new(&mut self.writer).write_all(b"\n").await?;
-        Pin::new(&mut self.writer).flush().await?;
+
+        let mut this = self.as_mut().project();
+        this.writer.write_all(json.as_bytes()).await?;
+        this.writer.write_all(b"\n").await?;
+        this.writer.flush().await?;
+
         Ok(())
     }
 }
@@ -139,6 +143,7 @@ where
     {
         use futures::StreamExt;
         let mut service = self.service;
+        let mut transport = Pin::new(&mut transport);
 
         tracing::info!("Server started");
         while let Some(msg_result) = transport.next().await {

examples/README.md

@@ -12,6 +12,8 @@ This directory contains examples demonstrating how to use the Model Context Prot
 
 The client examples demonstrate different ways to connect to MCP servers.
 
+Before running the examples, ensure you have `uv` installed. You can find the installation instructions [here](https://github.com/astral-sh/uv).
+
 ### Available Examples
 
 You can run the examples in two ways: