Implement remove_node

ros2-rust · Jul 29, 2023 · 5d1d03f · 5d1d03f
1 parent bde74f4
commit 5d1d03f
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/rclrs/src/lib.rs b/rclrs/src/lib.rs
@@ -57,6 +57,8 @@ impl SingleThreadedExecutor {
     }
 
     fn remove_node(&self, node: Arc<Node>) -> Result<(), RclrsError> {
+        { self.nodes_mtx.lock().unwrap() }
+            .retain(|n| !n.upgrade().map(|n| Arc::ptr_eq(&n, &node)).unwrap_or(false));
         Ok(())
     }