@@ -44,7 +44,7 @@ impl ProgressDispatcher {
4444 ProgressSubscriber {
4545 progress_token,
4646 receiver,
47- dispacher : self . dispatcher . clone ( ) ,
47+ dispatcher : self . dispatcher . clone ( ) ,
4848 }
4949 }
5050
@@ -53,17 +53,17 @@ impl ProgressDispatcher {
5353 self . dispatcher . write ( ) . await . remove ( token) ;
5454 }
5555
56- /// Clear all dispachter .
56+ /// Clear all dispatcher .
5757 pub async fn clear ( & self ) {
58- let mut dispacher = self . dispatcher . write ( ) . await ;
59- dispacher . clear ( ) ;
58+ let mut dispatcher = self . dispatcher . write ( ) . await ;
59+ dispatcher . clear ( ) ;
6060 }
6161}
6262
6363pub struct ProgressSubscriber {
6464 pub ( crate ) progress_token : ProgressToken ,
6565 pub ( crate ) receiver : ReceiverStream < ProgressNotificationParam > ,
66- pub ( crate ) dispacher : Dispatcher ,
66+ pub ( crate ) dispatcher : Dispatcher ,
6767}
6868
6969impl ProgressSubscriber {
@@ -91,10 +91,10 @@ impl Drop for ProgressSubscriber {
9191 fn drop ( & mut self ) {
9292 let token = self . progress_token . clone ( ) ;
9393 self . receiver . close ( ) ;
94- let dispatcher = self . dispacher . clone ( ) ;
94+ let dispatcher = self . dispatcher . clone ( ) ;
9595 tokio:: spawn ( async move {
96- let mut dispacher = dispatcher. write_owned ( ) . await ;
97- dispacher . remove ( & token) ;
96+ let mut dispatcher = dispatcher. write_owned ( ) . await ;
97+ dispatcher . remove ( & token) ;
9898 } ) ;
9999 }
100100}
0 commit comments