Public Member Functions | |
| def | __init__ (self, previous_handler) |
| def | finish (self, block=True) |
| def | handle_message (self, msg) |
| def | run (self) |
| def | transition (self) |
 Public Member Functions inherited from rosbridge_library.internal.subscription_modifiers.MessageHandler | |
| def | __init__ (self, previous_handler=None, publish=None) |
| def | set_queue_length (self, queue_length) |
| def | set_throttle_rate (self, throttle_rate) |
| def | time_remaining (self) |
Public Attributes | |
| alive | |
| c | |
| daemon | |
| queue | |
| queue_length | |
| throttle_rate | |
| Public Attributes inherited from rosbridge_library.internal.subscription_modifiers.MessageHandler | |
| last_publish | |
| publish | |
| queue_length | |
| throttle_rate | |
Detailed Description
Definition at line 105 of file subscription_modifiers.py.
Constructor & Destructor Documentation
◆ __init__()
| def rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.__init__ | ( | self, | |
| previous_handler | |||
| ) |
Definition at line 107 of file subscription_modifiers.py.
Member Function Documentation
◆ finish()
| def rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.finish | ( | self, | |
block = True |
|||
| ) |
If throttle was set to 0, this pushes all buffered messages
Reimplemented from rosbridge_library.internal.subscription_modifiers.MessageHandler.
Definition at line 142 of file subscription_modifiers.py.
◆ handle_message()
| def rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.handle_message | ( | self, | |
| msg | |||
| ) |
Reimplemented from rosbridge_library.internal.subscription_modifiers.MessageHandler.
Definition at line 116 of file subscription_modifiers.py.
◆ run()
| def rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.run | ( | self | ) |
Definition at line 152 of file subscription_modifiers.py.
◆ transition()
| def rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.transition | ( | self | ) |
Reimplemented from rosbridge_library.internal.subscription_modifiers.MessageHandler.
Definition at line 126 of file subscription_modifiers.py.
Member Data Documentation
◆ alive
| rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.alive |
Definition at line 113 of file subscription_modifiers.py.
◆ c
| rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.c |
Definition at line 112 of file subscription_modifiers.py.
◆ daemon
| rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.daemon |
Definition at line 110 of file subscription_modifiers.py.
◆ queue
| rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.queue |
Definition at line 111 of file subscription_modifiers.py.
◆ queue_length
| rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.queue_length |
Definition at line 127 of file subscription_modifiers.py.
◆ throttle_rate
| rosbridge_library.internal.subscription_modifiers.QueueMessageHandler.throttle_rate |
Definition at line 127 of file subscription_modifiers.py.
The documentation for this class was generated from the following file: