Bump up versions

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "stretto"
-version = "0.8.3"
+version = "0.8.4"
 authors = ["Al Liu <scygliu1@gmail.com>"]
 description = "Stretto is a high performance thread-safe memory-bound Rust cache."
 homepage = "https://github.com/al8n/stretto"
@@ -52,7 +52,7 @@ rand = "0.8"
 serde = { version = "1", optional = true, features = ["derive"] }
 serde_json = { version = "1", optional = true }
 seahash = "4.1"
-wg = "0.6"
+wg = "0.9"
 thiserror = "1"
 tracing = "0.1"
 xxhash-rust = { version = "0.8", features = ["xxh64"] }

src/cache.rs

@@ -739,7 +739,9 @@ macro_rules! impl_cache_cleaner {
                         expiration,
                     )),
                     $item::Delete { .. } | $item::Update { .. } => {}
-                    $item::Wait(wg) => wg.done(),
+                    $item::Wait(wg) => {
+                        let _ = wg.done();
+                    }
                 }
             }
         }

src/cache/test.rs

@@ -112,19 +112,13 @@ impl CacheCallback for TestCallbackDropUpdates {
 mod sync_test {
     use super::*;
     use crate::cache::sync::Item;
-    use crate::cache::test::{KHTest, TestCallback, TestCallbackDropUpdates, TestCoster};
     use crate::{
-        Cache, CacheBuilder, CacheCallback, Coster, DefaultCacheCallback, DefaultCoster,
-        DefaultKeyBuilder, DefaultUpdateValidator, KeyBuilder, TransparentKeyBuilder,
-        UpdateValidator,
+        Cache, CacheBuilder, DefaultCacheCallback, DefaultCoster, DefaultKeyBuilder,
+        DefaultUpdateValidator, TransparentKeyBuilder, UpdateValidator,
     };
     use crossbeam_channel::{bounded, select};
-    use parking_lot::Mutex;
     use std::collections::hash_map::RandomState;
-    use std::collections::HashSet;
     use std::hash::Hash;
-    use std::sync::atomic::{AtomicU64, Ordering};
-    use std::sync::Arc;
     use std::thread::{sleep, spawn};
     use std::time::Duration;
 
@@ -739,18 +733,11 @@ mod async_test {
     use super::*;
     use crate::cache::r#async::Item;
     use crate::{
-        AsyncCache, AsyncCacheBuilder, CacheCallback, Coster, DefaultCacheCallback, DefaultCoster,
-        DefaultKeyBuilder, DefaultUpdateValidator, KeyBuilder, TransparentKeyBuilder,
-        UpdateValidator,
+        AsyncCache, AsyncCacheBuilder, DefaultCacheCallback, DefaultCoster, DefaultKeyBuilder,
+        DefaultUpdateValidator, TransparentKeyBuilder, UpdateValidator,
     };
-    use parking_lot::Mutex;
-    use rand::rngs::OsRng;
-    use rand::Rng;
     use std::collections::hash_map::RandomState;
-    use std::collections::HashSet;
     use std::hash::Hash;
-    use std::sync::atomic::{AtomicU64, Ordering};
-    use std::sync::Arc;
     use std::time::Duration;
     use tokio::sync::mpsc::channel;
     use tokio::task::spawn;

src/lib.rs

@@ -345,9 +345,7 @@ impl<K: Hash + Eq> KeyBuilder for DefaultKeyBuilder<K> {
         Self::Key: core::borrow::Borrow<Q>,
         Q: core::hash::Hash + Eq + ?Sized,
     {
-        let mut s = self.sea.build_hasher();
-        key.hash(&mut s);
-        s.finish()
+        self.sea.hash_one(key)
     }
 
     #[inline]
@@ -356,9 +354,7 @@ impl<K: Hash + Eq> KeyBuilder for DefaultKeyBuilder<K> {
         Self::Key: core::borrow::Borrow<Q>,
         Q: core::hash::Hash + Eq + ?Sized,
     {
-        let mut x = self.xx.build_hasher();
-        key.hash(&mut x);
-        x.finish()
+        self.xx.hash_one(key)
     }
 }
 

src/store.rs

@@ -4,7 +4,6 @@ use crate::{CacheError, DefaultUpdateValidator, Item as CrateItem, UpdateValidat
 use parking_lot::RwLock;
 use std::collections::hash_map::RandomState;
 use std::collections::HashMap;
-use std::convert::TryInto;
 use std::fmt::{Debug, Formatter};
 use std::hash::BuildHasher;
 use std::mem;

src/utils.rs

@@ -20,7 +20,6 @@ use parking_lot::{RwLockReadGuard, RwLockWriteGuard};
 use std::cell::UnsafeCell;
 use std::collections::hash_map::RandomState;
 use std::collections::HashMap;
-use std::convert::TryInto;
 use std::fmt::{Debug, Display, Formatter};
 use std::hash::BuildHasher;
 use std::time::Duration;