From 4f9a4788d9c046091e99a8a6da12aa4cdfa9196f Mon Sep 17 00:00:00 2001 From: Yashash H L Date: Wed, 15 Jan 2025 10:03:34 +0530 Subject: [PATCH] update comment Signed-off-by: Yashash H L --- rust/serving/src/app/tracker.rs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/rust/serving/src/app/tracker.rs b/rust/serving/src/app/tracker.rs index 9cdaa7185..311a1edae 100644 --- a/rust/serving/src/app/tracker.rs +++ b/rust/serving/src/app/tracker.rs @@ -165,9 +165,8 @@ impl MessageGraph { // iterate over the responses of the current callback, for flatmap operation there can // more than one response, so we need to make sure all the responses are processed. - // For example a -> b -> c, lets say vertex a has 2 responses. That means we need to - // wait for two callbacks from vertex b, each message from vertex b can have 2 responses - // we will have to wait for 4 callbacks from vertex c. + // For example a -> b -> c, lets say vertex a has 2 responses. We will have to recursively + // find the subgraph for both the responses. for response in current_callback.responses.clone() { // recursively invoke the downstream vertices of the current vertex, if any if let Some(edges) = self.dag.get(¤t) {