streaming improved with Result (error)

fraktalio · Jan 3, 2025 · b16f64f · b16f64f
1 parent fe105ee
commit b16f64f
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/src/adapter/event_stream/saga_stream.rs b/src/adapter/event_stream/saga_stream.rs
@@ -61,7 +61,6 @@ pub async fn stream_events_to_saga(
             Ok(())
         }
         Err(error) => {
-            // Handle the error, optionally break the loop based on the error
             error!("Error: {}", error.message);
             Err(ErrorMessage {
                 message: error.message,

diff --git a/src/adapter/event_stream/view_stream.rs b/src/adapter/event_stream/view_stream.rs
@@ -92,7 +92,6 @@ pub async fn stream_events_to_view(
             Ok(())
         }
         Err(error) => {
-            // Handle the error
             error!("Error: {}", error.message);
             Err(ErrorMessage {
                 message: error.message,