chore: typos

Author: hashemix

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

@@ -454,9 +454,9 @@ impl ClientRuntime {
             let result = transport.send_message(messages, timeout).await?;
 
             if no_session_id {
-                if let Some(resquest_id) = transport.session_id().await.clone() {
+                if let Some(request_id) = transport.session_id().await.clone() {
                     let mut guard = self.session_id.write().await;
-                    *guard = Some(resquest_id)
+                    *guard = Some(request_id)
                 }
             }
 
@@ -515,7 +515,7 @@ impl ClientRuntime {
         // Run both tasks with cancellation logic
         let (send_res, _) = tokio::select! {
             res = &mut send_task => {
-                // cancel the receive_task task, to cover the case where sned_task returns with error
+                // cancel the receive_task task, to cover the case where send_task returns with error
                 abort_recv_handle.abort();
                 (res, receive_task.await) // Wait for receive_task to finish (it should exit due to cancellation)
             }

crates/rust-mcp-sdk/tests/common/test_client.rs

@@ -89,7 +89,7 @@ pub mod test_client_common {
     ) -> InitializedClient {
         let mock_server = MockServer::start().await;
 
-        // intialize response
+        // initialize response
         let mut response = create_sse_response(INITIALIZE_RESPONSE);
 
         if let Some(session_id) = session_id {

crates/rust-mcp-sdk/tests/test_streamable_http_client.rs

@@ -39,7 +39,7 @@ async fn should_send_json_rpc_messages_via_post() {
     // Start a mock server
     let mock_server = MockServer::start().await;
 
-    // intialize response
+    // initialize response
     let response = create_sse_response(INITIALIZE_RESPONSE);
 
     // initialize request and response
@@ -137,7 +137,7 @@ async fn should_store_session_id_received_during_initialization() {
     // Start a mock server
     let mock_server = MockServer::start().await;
 
-    // intialize response
+    // initialize response
     let response =
         create_sse_response(INITIALIZE_RESPONSE).append_header("mcp-session-id", "test-session-id");
 
@@ -283,7 +283,7 @@ async fn should_handle_successful_initial_get_connection_for_sse() {
     // Start a mock server
     let mock_server = MockServer::start().await;
 
-    // intialize response
+    // initialize response
     let response = create_sse_response(INITIALIZE_RESPONSE);
 
     // initialize request and response
@@ -394,7 +394,7 @@ async fn should_attempt_initial_get_connection_and_handle_405_gracefully() {
     // Start a mock server
     let mock_server = MockServer::start().await;
 
-    // intialize response
+    // initialize response
     let response = create_sse_response(INITIALIZE_RESPONSE);
 
     // initialize request and response
@@ -445,7 +445,7 @@ async fn should_attempt_initial_get_connection_and_handle_405_gracefully() {
 
     assert!(get_request.is_some());
 
-    // send a batch message, runtime should work as expected with no isse
+    // send a batch message, runtime should work as expected with no issue
 
     let response = create_sse_response(
         r#"[{"id":"id1","jsonrpc":"2.0", "result":{}},{"id":"id2","jsonrpc":"2.0", "result":{}}]"#,
@@ -616,7 +616,7 @@ async fn should_reconnect_a_get_initiated_notification_stream_that_fails() {
     // Start a mock server
     let mock_server = MockServer::start().await;
 
-    // intialize response
+    // initialize response
     let response = create_sse_response(INITIALIZE_RESPONSE);
 
     // initialize request and response
@@ -726,7 +726,7 @@ async fn should_pass_last_event_id_when_reconnecting() {
     assert!(get_requests.len() > 1);
 
     let Some(last_get_request) = get_requests.last() else {
-        panic!("Unable to find last GET reuest!");
+        panic!("Unable to find last GET request!");
     };
 
     let last_event_id = last_get_request

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

@@ -62,7 +62,7 @@ impl fmt::Debug for SseEvent {
 }
 
 /// A parser for Server-Sent Events (SSE) that processes incoming byte chunks into `SseEvent`s.
-/// This Parser is specificly designed for MCP messages and with no multi-line data support
+/// This Parser is specifically designed for MCP messages and with no multi-line data support
 ///
 /// This struct maintains a buffer to accumulate incoming data and parses it into SSE events
 /// based on the SSE protocol. It handles fields like `event`, `data`, and `id` as defined

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

@@ -130,7 +130,7 @@ impl StreamableHttpStream {
                     match chunk {
                         Some(chunk) => chunk,
                         None => {
-                            // stream ended, unline SSE, so no retry attempt here needed to reconnect
+                            // stream ended, unlike SSE, so no retry attempt here needed to reconnect
                             return Err(TransportError::Internal("Stream has ended.".to_string()));
                         }
                     }
@@ -315,7 +315,7 @@ impl StreamableHttpStream {
                         match chunk {
                             Some(chunk) => chunk,
                             None => {
-                                // stream ended, unline SSE, so no retry attempt here needed to reconnect
+                                // stream ended, unlike SSE, so no retry attempt here needed to reconnect
                                 return Err(TransportError::Internal("Stream has ended.".to_string()));
                             }
                         }