diff --git a/core/sdk/src/extn/client/extn_client.rs b/core/sdk/src/extn/client/extn_client.rs index 375b8cb6e..39f276743 100644 --- a/core/sdk/src/extn/client/extn_client.rs +++ b/core/sdk/src/extn/client/extn_client.rs @@ -390,10 +390,10 @@ impl ExtnClient { trace!("Send to other client result: {:?}", send_res); } } + Self::handle_vec_stream(message, self.event_processors.clone()); } else { trace!("Context information is already updated. Hence not propagating"); } - Self::handle_vec_stream(message, self.event_processors.clone()); } fn has_event_listener(&self, input: &str) -> bool {