chore: fix clippy 1.84 (#4319)

* chore: remove not used lifetimes

* chore: remove redundant as_bytes() when getting len

* chore: bump versions

crates/fluvio-compression/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "fluvio-compression"
-version = "0.3.4"
+version = "0.3.5"
 edition = "2021"
 license = "Apache-2.0"
 authors = ["Fluvio Contributors <[email protected]>"]

crates/fluvio-compression/src/gzip.rs

@@ -30,7 +30,7 @@ mod tests {
         let text = "FLUVIO_AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA";
         let compressed = compress(text.as_bytes()).unwrap();
 
-        assert!(compressed.len() < text.as_bytes().len());
+        assert!(compressed.len() < text.len());
 
         let uncompressed = String::from_utf8(uncompress(compressed.reader()).unwrap()).unwrap();
 

crates/fluvio-compression/src/lz4.rs

@@ -28,7 +28,7 @@ mod tests {
         let text = "FLUVIO_AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA";
         let compressed = compress(text.as_bytes()).unwrap();
 
-        assert!(compressed.len() < text.as_bytes().len());
+        assert!(compressed.len() < text.len());
 
         let uncompressed = String::from_utf8(uncompress(compressed.reader()).unwrap()).unwrap();
 

crates/fluvio-compression/src/snappy.rs

@@ -31,7 +31,7 @@ mod tests {
         let text = "FLUVIO_AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA";
         let compressed = compress(text.as_bytes()).unwrap();
 
-        assert!(compressed.len() < text.as_bytes().len());
+        assert!(compressed.len() < text.len());
 
         let uncompressed = String::from_utf8(uncompress(compressed.reader()).unwrap()).unwrap();
 

crates/fluvio-compression/src/zstd.rs

@@ -28,7 +28,7 @@ mod tests {
         let text = "FLUVIO_AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA";
         let compressed = compress(text.as_bytes()).unwrap();
 
-        assert!(compressed.len() < text.as_bytes().len());
+        assert!(compressed.len() < text.len());
 
         let uncompressed = String::from_utf8(uncompress(compressed.reader()).unwrap()).unwrap();
 

crates/fluvio-stream-model/Cargo.toml

@@ -1,7 +1,7 @@
 [package]
 name = "fluvio-stream-model"
 edition = "2021"
-version = "0.11.4"
+version = "0.11.5"
 authors = ["Fluvio Contributors <[email protected]>"]
 description = "Fluvio Event Stream Model"
 repository = "https://github.com/infinyon/fluvio"

crates/fluvio-stream-model/src/store/concurrent_hashmap.rs

@@ -23,11 +23,11 @@ where
         lock.insert(key, value)
     }
 
-    pub async fn read<'a>(&'_ self) -> RwLockReadGuard<'_, HashMap<K, V>> {
+    pub async fn read(&'_ self) -> RwLockReadGuard<'_, HashMap<K, V>> {
         self.0.read().await
     }
 
-    pub async fn write<'a>(&'_ self) -> RwLockWriteGuard<'_, HashMap<K, V>> {
+    pub async fn write(&'_ self) -> RwLockWriteGuard<'_, HashMap<K, V>> {
         self.0.write().await
     }
 
@@ -69,11 +69,11 @@ where
         Self(RwLock::new(map))
     }
 
-    pub async fn read<'a>(&'_ self) -> RwLockReadGuard<'_, BTreeMap<K, V>> {
+    pub async fn read(&'_ self) -> RwLockReadGuard<'_, BTreeMap<K, V>> {
         self.0.read().await
     }
 
-    pub async fn write<'a>(&'_ self) -> RwLockWriteGuard<'_, BTreeMap<K, V>> {
+    pub async fn write(&'_ self) -> RwLockWriteGuard<'_, BTreeMap<K, V>> {
         self.0.write().await
     }
 

crates/fluvio-stream-model/src/store/dual_store.rs

@@ -74,15 +74,15 @@ where
 
     /// Read guard
     #[inline(always)]
-    pub async fn read<'a>(
+    pub async fn read(
         &'_ self,
     ) -> RwLockReadGuard<'_, DualEpochMap<S::IndexKey, MetadataStoreObject<S, C>>> {
         self.store.read().await
     }
 
     /// write guard, this is private, use sync API to make changes
     #[inline(always)]
-    async fn write<'a>(
+    async fn write(
         &'_ self,
     ) -> RwLockWriteGuard<'_, DualEpochMap<S::IndexKey, MetadataStoreObject<S, C>>> {
         self.store.write().await

crates/fluvio/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "fluvio"
-version = "0.24.2"
+version = "0.24.3"
 edition = "2021"
 license = "Apache-2.0"
 authors = ["Fluvio Contributors <[email protected]>"]

crates/fluvio/src/producer/partition_producer.rs

@@ -167,7 +167,7 @@ where
             let mut batches = self.batches_lock.batches.lock().await;
             while !batches.is_empty() {
                 let ready = force
-                    || batches.front().map_or(false, |batch| {
+                    || batches.front().is_some_and(|batch| {
                         batch.is_full() || batch.elapsed() as u128 >= self.config.linger.as_millis()
                     });
                 if ready {