chore: remove async where not needed

Author: hashemix

crates/rust-mcp-sdk/src/mcp_runtimes/client_runtime.rs

@@ -76,13 +76,13 @@ impl McpClient for ClientRuntime {
     where
         MessageDispatcher<ServerMessage>: McpDispatch<ServerMessage, MessageFromClient>,
     {
-        (self.transport.message_sender().await) as _
+        (self.transport.message_sender()) as _
     }
 
     async fn start(self: Arc<Self>) -> SdkResult<()> {
         let mut stream = self.transport.start().await?;
 
-        let mut error_io_stream = self.transport.error_stream().await.write().await;
+        let mut error_io_stream = self.transport.error_stream().write().await;
         let error_io_stream = error_io_stream.take();
 
         let self_clone = Arc::clone(&self);

crates/rust-mcp-sdk/src/mcp_runtimes/server_runtime.rs

@@ -66,14 +66,14 @@ impl McpServer for ServerRuntime {
     where
         MessageDispatcher<ClientMessage>: McpDispatch<ClientMessage, MessageFromServer>,
     {
-        (self.transport.message_sender().await) as _
+        (self.transport.message_sender()) as _
     }
 
     /// Main runtime loop, processes incoming messages and handles requests
     async fn start(&self) -> SdkResult<()> {
         let mut stream = self.transport.start().await?;
 
-        let sender = self.transport.message_sender().await.read().await;
+        let sender = self.transport.message_sender().read().await;
         let sender = sender
             .as_ref()
             .ok_or(schema_utils::SdkError::connection_closed())?;
@@ -124,7 +124,7 @@ impl McpServer for ServerRuntime {
     }
 
     async fn stderr_message(&self, message: String) -> SdkResult<()> {
-        let mut lock = self.transport.error_stream().await.write().await;
+        let mut lock = self.transport.error_stream().write().await;
         if let Some(IoStream::Writable(stderr)) = lock.as_mut() {
             stderr.write_all(message.as_bytes()).await?;
             stderr.write_all(b"\n").await?;

crates/rust-mcp-transport/src/client_sse.rs

@@ -316,11 +316,11 @@ where
         Ok(stream)
     }
 
-    async fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>> {
+    fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>> {
         &self.message_sender as _
     }
 
-    async fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>> {
+    fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>> {
         &self.error_stream as _
     }
 

crates/rust-mcp-transport/src/sse.rs

@@ -139,11 +139,11 @@ where
         *result
     }
 
-    async fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>> {
+    fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>> {
         &self.message_sender as _
     }
 
-    async fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>> {
+    fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>> {
         &self.error_stream as _
     }
 

crates/rust-mcp-transport/src/stdio.rs

@@ -254,11 +254,11 @@ where
         *result
     }
 
-    async fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>> {
+    fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>> {
         &self.message_sender as _
     }
 
-    async fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>> {
+    fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>> {
         &self.error_stream as _
     }
 

crates/rust-mcp-transport/src/transport.rs

@@ -113,8 +113,8 @@ where
     async fn start(&self) -> TransportResult<Pin<Box<dyn Stream<Item = R> + Send>>>
     where
         MessageDispatcher<R>: McpDispatch<R, S>;
-    async fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>>;
-    async fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>>;
+    fn message_sender(&self) -> &tokio::sync::RwLock<Option<MessageDispatcher<R>>>;
+    fn error_stream(&self) -> &tokio::sync::RwLock<Option<IoStream>>;
     async fn shut_down(&self) -> TransportResult<()>;
     async fn is_shut_down(&self) -> bool;
 }