niryo_libraries.rosbridge_library.internal.subscribers.SubscriberManager

class documentation

class SubscriberManager:

Keeps track of client subscriptions

Method	`__init__`	Undocumented
Method	`subscribe`	Subscribe to a topic
Method	`unsubscribe`	Unsubscribe from a topic
Instance Variable	`_lock`	Undocumented
Instance Variable	`_subscribers`	Undocumented

def __init__(self): ¶

Undocumented

def subscribe(self, client_id, topic, callback, msg_type=None): ¶

Subscribe to a topic

Keyword arguments: client_id -- the ID of the client making this subscribe request topic -- the name of the topic to subscribe to callback -- the callback to call for incoming messages on the topic msg_type -- (optional) the type of the topic

def unsubscribe(self, client_id, topic): ¶

Unsubscribe from a topic

Keyword arguments: client_id -- the ID of the client to unsubscribe topic -- the topic to unsubscribe from

_lock = ¶

Undocumented

_subscribers: dict = ¶

Undocumented