From 2d5f74375b79df9b2a7e7dec5da14a57fec72f8a Mon Sep 17 00:00:00 2001 From: xiaohan <95028555@qq.com> Date: Tue, 9 Sep 2025 14:26:33 +0800 Subject: [PATCH] fix:crates/rmcp/src/handler/client/progress.rs dispacher-> dispatcher --- .gitignore | 1 + crates/rmcp/src/handler/client/progress.rs | 16 ++++++++-------- 2 files changed, 9 insertions(+), 8 deletions(-) diff --git a/.gitignore b/.gitignore index c858b579e..bb88a0e2f 100644 --- a/.gitignore +++ b/.gitignore @@ -13,6 +13,7 @@ Cargo.lock # MSVC Windows builds of rustc generate these, which store debugging information *.pdb .vscode/ +.idea # Python artifacts (for test directories) *.egg-info/ diff --git a/crates/rmcp/src/handler/client/progress.rs b/crates/rmcp/src/handler/client/progress.rs index cb2ec3140..04f31610f 100644 --- a/crates/rmcp/src/handler/client/progress.rs +++ b/crates/rmcp/src/handler/client/progress.rs @@ -44,7 +44,7 @@ impl ProgressDispatcher { ProgressSubscriber { progress_token, receiver, - dispacher: self.dispatcher.clone(), + dispatcher: self.dispatcher.clone(), } } @@ -53,17 +53,17 @@ impl ProgressDispatcher { self.dispatcher.write().await.remove(token); } - /// Clear all dispachter. + /// Clear all dispatcher. pub async fn clear(&self) { - let mut dispacher = self.dispatcher.write().await; - dispacher.clear(); + let mut dispatcher = self.dispatcher.write().await; + dispatcher.clear(); } } pub struct ProgressSubscriber { pub(crate) progress_token: ProgressToken, pub(crate) receiver: ReceiverStream, - pub(crate) dispacher: Dispatcher, + pub(crate) dispatcher: Dispatcher, } impl ProgressSubscriber { @@ -91,10 +91,10 @@ impl Drop for ProgressSubscriber { fn drop(&mut self) { let token = self.progress_token.clone(); self.receiver.close(); - let dispatcher = self.dispacher.clone(); + let dispatcher = self.dispatcher.clone(); tokio::spawn(async move { - let mut dispacher = dispatcher.write_owned().await; - dispacher.remove(&token); + let mut dispatcher = dispatcher.write_owned().await; + dispatcher.remove(&token); }); } }