fix typo

volo-thrift/src/transport/multiplex/utils.rs

@@ -5,13 +5,13 @@ use tokio::sync::Mutex;
 const SHARD_COUNT: usize = 64;
 
 pub struct TxHashMap<T> {
-    shared: [Mutex<fxhash::FxHashMap<i32, T>>; SHARD_COUNT],
+    sharded: [Mutex<fxhash::FxHashMap<i32, T>>; SHARD_COUNT],
 }
 
 impl<T> Default for TxHashMap<T> {
     fn default() -> Self {
         TxHashMap {
-            shared: array::from_fn(|_| Default::default()),
+            sharded: array::from_fn(|_| Default::default()),
         }
     }
 }
@@ -21,14 +21,14 @@ where
     T: Sized,
 {
     pub async fn remove(&self, key: &i32) -> Option<T> {
-        self.shared[(*key % (SHARD_COUNT as i32)) as usize]
+        self.sharded[(*key % (SHARD_COUNT as i32)) as usize]
             .lock()
             .await
             .remove(key)
     }
 
     pub async fn is_empty(&self) -> bool {
-        for s in self.shared.iter() {
+        for s in self.sharded.iter() {
             if !s.lock().await.is_empty() {
                 return false;
             }
@@ -37,15 +37,15 @@ where
     }
 
     pub async fn insert(&self, key: i32, value: T) -> Option<T> {
-        self.shared[(key % (SHARD_COUNT as i32)) as usize]
+        self.sharded[(key % (SHARD_COUNT as i32)) as usize]
             .lock()
             .await
             .insert(key, value)
     }
 
     pub async fn for_all_drain(&self, mut f: impl FnMut(T) -> ()) {
-        for shared in self.shared.iter() {
-            let mut s = shared.lock().await;
+        for sharded in self.sharded.iter() {
+            let mut s = sharded.lock().await;
             for data in s.drain() {
                 f(data.1)
             }