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()
     ///       }
     ///     }