From 9faa449f625337a9aec591c43d097faeebf0d169 Mon Sep 17 00:00:00 2001 From: John Yang Date: Thu, 24 Oct 2024 16:11:39 -0700 Subject: [PATCH] Remove qualifying name for reducer interface --- src/lib.rs | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/src/lib.rs b/src/lib.rs index cb7adf1..296e686 100644 --- 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> + Send; - fn flush(&mut self) -> impl std::future::Future> + Send; + fn reduce(&mut self, t: Self::Item) -> impl Future> + Send; + fn flush(&mut self) -> impl Future> + Send; fn reset(&mut self); fn is_full(&self) -> bool; fn get_reduce_config(&self) -> ReduceConfig;