Remove qualifying name for reducer interface

john-z-yang · Oct 24, 2024 · 9faa449 · 9faa449
1 parent 9261674
commit 9faa449
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -484,11 +484,8 @@ pub enum ReduceShutdownBehaviour {
 pub trait Reducer {
     type Item;
 
-    fn reduce(
-        &mut self,
-        t: Self::Item,
-    ) -> impl std::future::Future<Output = Result<(), anyhow::Error>> + Send;
-    fn flush(&mut self) -> impl std::future::Future<Output = Result<(), anyhow::Error>> + Send;
+    fn reduce(&mut self, t: Self::Item) -> impl Future<Output = Result<(), anyhow::Error>> + Send;
+    fn flush(&mut self) -> impl Future<Output = Result<(), anyhow::Error>> + Send;
     fn reset(&mut self);
     fn is_full(&self) -> bool;
     fn get_reduce_config(&self) -> ReduceConfig;