Refactoring

Signed-off-by: Sreekanth <[email protected]>
numaproj · Jan 17, 2025 · e6467a2 · e6467a2
1 parent 45dfcd3
commit e6467a2
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/rust/numaflow-core/src/tracker.rs b/rust/numaflow-core/src/tracker.rs
@@ -346,14 +346,16 @@ impl TrackerHandle {
         offset: Bytes,
         message_tags: Option<Arc<[String]>>,
     ) -> Result<()> {
-        let mut responses: Option<Vec<String>> = None;
-        if self.enable_callbacks {
-            if let Some(tags) = message_tags {
+        let responses: Option<Vec<String>> = match (self.enable_callbacks, message_tags) {
+            (true, Some(tags)) => {
                 if !tags.is_empty() {
-                    responses = Some(tags.iter().cloned().collect());
+                    Some(tags.iter().cloned().collect::<Vec<String>>())
+                } else {
+                    None
                 }
-            };
-        }
+            }
+            _ => None,
+        };
         let message = ActorMessage::Update { offset, responses };
         self.sender
             .send(message)