From d15690f82c94d014163dac2d9ab9ddc7415f71a9 Mon Sep 17 00:00:00 2001
From: shubham <shubhamdixit863@gmail.com>
Date: Wed, 22 May 2024 18:37:28 +0530
Subject: [PATCH] fixes for the reduce

Signed-off-by: shubham <shubhamdixit863@gmail.com>
---
 src/reduce.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/reduce.rs b/src/reduce.rs
index 4dd09be..43893ff 100644
--- a/src/reduce.rs
+++ b/src/reduce.rs
@@ -109,7 +109,7 @@ pub trait Reducer {
     ///    impl numaflow::reduce::ReducerCreator for CounterCreator {
     ///        type R = Counter;
     ///
-    ///        fn create(&self) -> Counter {
+    ///        fn create(&self) -> Self::R {
     ///           Counter::new()
     ///       }
     ///     }