Only update matching listener status for last remote subscriber

eclipse-zenoh · Dec 10, 2024 · 86fcca0 · 86fcca0
1 parent 59c04bf
commit 86fcca0
Showing 1 changed file with 20 additions and 10 deletions.
diff --git a/zenoh/src/api/session.rs b/zenoh/src/api/session.rs
@@ -1574,21 +1574,31 @@ impl SessionInner {
                                     },
                                 }),
                             });
+                            #[cfg(feature = "unstable")]
+                            {
+                                let state = zread!(self.state);
+                                self.update_matching_status(
+                                    &state,
+                                    &sub_state.key_expr,
+                                    MatchingStatusType::Subscribers,
+                                    false,
+                                )
+                            }
                         } else {
                             drop(state);
                         }
                     } else {
                         drop(state);
-                    }
-                    #[cfg(feature = "unstable")]
-                    {
-                        let state = zread!(self.state);
-                        self.update_matching_status(
-                            &state,
-                            &sub_state.key_expr,
-                            MatchingStatusType::Subscribers,
-                            false,
-                        )
+                        #[cfg(feature = "unstable")]
+                        {
+                            let state = zread!(self.state);
+                            self.update_matching_status(
+                                &state,
+                                &sub_state.key_expr,
+                                MatchingStatusType::Subscribers,
+                                false,
+                            )
+                        }
                     }
                 }
                 SubscriberKind::LivelinessSubscriber => {