Updated Zenoh subscriber and queryable declarations to undeclare enti…

…ties when references are dropped. (#173)
eclipse-zenoh · Oct 3, 2024 · 64e9830 · 64e9830
1 parent 540c1ad
commit 64e9830
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 0 deletions.
diff --git a/zenoh-plugin-ros1/examples/ros1_pub.rs b/zenoh-plugin-ros1/examples/ros1_pub.rs
@@ -60,6 +60,7 @@ async fn main() {
     let zenoh_subscriber = zenoh_session
         .declare_subscriber("some/ros/topic")
         .callback(|data| println!("Zenoh Subscriber: got data!"))
+        .undeclare_on_drop(true)
         .await
         .unwrap();
     println!(" OK!");

diff --git a/zenoh-plugin-ros1/src/ros_to_zenoh_bridge/aloha_declaration.rs b/zenoh-plugin-ros1/src/ros_to_zenoh_bridge/aloha_declaration.rs
@@ -68,6 +68,7 @@ impl AlohaDeclaration {
             .callback(move |_| {
                 rb.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
             })
+            .undeclare_on_drop(true)
             .await
             .unwrap();
 

diff --git a/zenoh-plugin-ros1/src/ros_to_zenoh_bridge/zenoh_client.rs b/zenoh-plugin-ros1/src/ros_to_zenoh_bridge/zenoh_client.rs
@@ -48,6 +48,7 @@ impl ZenohClient {
         self.session
             .declare_subscriber(key_expr)
             .callback(callback)
+            .undeclare_on_drop(true)
             .allowed_origin(Locality::Remote)
             .await
     }
@@ -86,6 +87,7 @@ impl ZenohClient {
             .declare_queryable(key_expr)
             .allowed_origin(Locality::Remote)
             .callback(callback)
+            .undeclare_on_drop(true)
             .await
     }
 

diff --git a/zenoh-plugin-ros1/tests/aloha_declaration_test.rs b/zenoh-plugin-ros1/tests/aloha_declaration_test.rs
@@ -110,6 +110,7 @@ impl PPCMeasurement {
             .callback(move |_val| {
                 p.fetch_add(1, std::sync::atomic::Ordering::SeqCst);
             })
+            .undeclare_on_drop(true)
             .await?;
 
         Ok(Self {