rosbridge_library.internal.subscription_modifiers module

class rosbridge_library.internal.subscription_modifiers.MessageHandler(previous_handler=None, publish=None)

Bases: object

finish(block=True)

handle_message(msg)

set_queue_length(queue_length)

set_throttle_rate(throttle_rate)

time_remaining()

transition()

class rosbridge_library.internal.subscription_modifiers.QueueMessageHandler(previous_handler)

Bases: MessageHandler, Thread

finish(block=True)

Notify the thread to finish, and optionally wait for it to finish.

If throttle was set to 0, this pushes all buffered messages.

Parameters:

block – If True, wait for the thread to finish before returning

handle_message(msg)

run()

Method representing the thread’s activity.

You may override this method in a subclass. The standard run() method invokes the callable object passed to the object’s constructor as the target argument, if any, with sequential and keyword arguments taken from the args and kwargs arguments, respectively.

transition()

class rosbridge_library.internal.subscription_modifiers.ThrottleMessageHandler(previous_handler=None, publish=None)

Bases: MessageHandler

finish(block=True)

handle_message(msg)

transition()