From a1b554b4fa3d4b1fb00d6c787afd020fb52d7219 Mon Sep 17 00:00:00 2001 From: Daisuke Sato Date: Wed, 6 Apr 2022 08:23:08 +0900 Subject: [PATCH] Add "remove_subscriber" https://github.com/Unity-Technologies/ROS-TCP-Connector/pull/196/files#diff-fbf6c2f2a1a7feb6b363ab04f47f6ea0f3ceefa1c75138f030c78deb84aab60fR161-R167 --- src/ros_tcp_endpoint/server.py | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/src/ros_tcp_endpoint/server.py b/src/ros_tcp_endpoint/server.py index a8dd528..7492b23 100644 --- a/src/ros_tcp_endpoint/server.py +++ b/src/ros_tcp_endpoint/server.py @@ -283,3 +283,9 @@ def resolve_message_name(self, name, extension="msg"): except (IndexError, KeyError, AttributeError, ImportError) as e: self.tcp_server.logerr("Failed to resolve message name: {}".format(e)) return None + + def remove_subscriber(self, topic): + old_subscriber = self.tcp_server.subscribers_table[topic] + old_subscriber.unregister() + del self.tcp_server.subscribers_table[topic] + self.tcp_server.loginfo("UnregisterSubscriber({}) OK".format(topic))