Lint

john-z-yang · Nov 4, 2024 · 03437d4 · 03437d4
1 parent fc26456
commit 03437d4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/Cargo.toml b/Cargo.toml
@@ -18,4 +18,4 @@ tracing = "0.1.40"
 tracing-subscriber = "0.3.18"
 reqwest = { version = "0.12.8", features = ["json", "stream"] }
 serde = "1.0.210"
-serde_json = "1.0.128"
+serde_json = "1.0.128"
diff --git a/src/lib.rs b/src/lib.rs
@@ -806,7 +806,7 @@ mod tests {
 
     use crate::{
         commit, map, reduce, reduce_err, CommitClient, KafkaMessage, MessageQueue, ReduceConfig,
-        ReduceShutdownBehaviour, ReduceShutdownCondition, Reducer,
+        ReduceShutdownBehaviour, ReduceShutdownCondition, Reducer, ReducerWhenFullBehaviour,
     };
 
     struct MockCommitClient {
@@ -877,7 +877,7 @@ mod tests {
             ReduceConfig {
                 shutdown_condition: ReduceShutdownCondition::Signal,
                 shutdown_behaviour: ReduceShutdownBehaviour::Drop,
-                when_full_behaviour: crate::ReducerWhenFullBehaviour::Flush,
+                when_full_behaviour: ReducerWhenFullBehaviour::Flush,
                 flush_interval: None,
             }
         }
@@ -959,11 +959,11 @@ mod tests {
             self.buffer.read().unwrap().len() >= 32
         }
 
-        fn get_reduce_config(&self) -> crate::ReduceConfig {
+        fn get_reduce_config(&self) -> ReduceConfig {
             ReduceConfig {
                 shutdown_condition: self.shutdown_condition,
                 shutdown_behaviour: ReduceShutdownBehaviour::Flush,
-                when_full_behaviour: crate::ReducerWhenFullBehaviour::Backpressure,
+                when_full_behaviour: ReducerWhenFullBehaviour::Backpressure,
                 flush_interval: Some(Duration::from_secs(1)),
             }
         }