update doc

Signed-off-by: Yashash H L <yashashhl25@gmail.com>
numaproj · May 5, 2024 · 3d5b3eb · 3d5b3eb
1 parent be65eaa
commit 3d5b3eb
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/src/reduce.rs b/src/reduce.rs
@@ -42,9 +42,10 @@ pub trait Reducer {
     /// Below is a reduce code to count the number of elements for a given set of keys and window.
     ///
     /// ```no_run
+    /// use numaflow::reduce;
+    ///
     /// #[tokio::main]
-    /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    ///     use numaflow::reduce;
+    /// async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
     /// let reduce_handler = counter::Counter::new();
     ///     reduce::Server::new(reduce_handler).start().await?;
     ///     Ok(())

diff --git a/src/sideinput.rs b/src/sideinput.rs
@@ -32,6 +32,7 @@ pub trait SideInputer {
     /// use numaflow::sideinput::SideInputer;
     /// use tonic::{async_trait};
     /// use std::sync::Mutex;
+    /// use numaflow::sideinput;
     ///
     /// struct SideInputHandler {
     ///     counter: Mutex<u32>,
@@ -65,8 +66,8 @@ pub trait SideInputer {
     /// }
     ///
     /// #[tokio::main]
-    /// async fn main() -> Result<(), Box<dyn std::error::Error>> {
-    ///     use numaflow::sideinput;
+    /// async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
+    ///
     /// let side_input_handler = SideInputHandler::new();
     ///     sideinput::Server::new(side_input_handler).start().await?;
     ///     Ok(())