Node holds separate list for wsubscribers

robotics-4-all · Jan 10, 2025 · 0d84311 · 0d84311
1 parent 3c1c9fc
commit 0d84311
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/commlib/node.py b/commlib/node.py
@@ -157,6 +157,7 @@ def __init__(self,
 
         self._publishers = []
         self._subscribers = []
+        self._wsubscribers = []
         self._rpc_services = []
         self._rpc_clients = []
         self._action_services = []
@@ -194,7 +195,7 @@ def ports(self):
     @property
     def endpoints(self):
         return self._subscribers + self._publishers + self._rpc_services + self._rpc_clients + \
-            self._action_services + self._action_clients
+            self._action_services + self._action_clients + self._wsubscribers
 
     @property
     def health(self):
@@ -466,7 +467,7 @@ def create_wsubscriber(self, *args, **kwargs):
             *args,
             **kwargs,
         )
-        self._subscribers.append(sub)
+        self._wsubscribers.append(sub)
         return sub
 
     def create_rpc(self, *args, **kwargs):