|
def | __init__ (self, args=None, **kwargs) |
|
def | close (self) |
|
def | is_processable (self, topic, msg, stamp, index=None) |
|
def | mark_queue (self, topic, msg, stamp) |
|
def | push (self, topic, msg=None, stamp=None) |
|
def | read (self) |
|
def | read_queue (self) |
|
def | __enter__ (self) |
|
def | __exit__ (self, exc_type, exc_value, traceback) |
|
def | __iter__ (self) |
|
def | bind (self, sink) |
|
def | close_batch (self) |
|
def | format_message_meta (self, topic, msg, stamp, index=None) |
|
def | format_meta (self) |
|
def | get_batch (self) |
|
def | get_message_class (self, typename, typehash=None) |
|
def | get_message_definition (self, msg_or_type) |
|
def | get_message_meta (self, topic, msg, stamp, index=None) |
|
def | get_message_type_hash (self, msg_or_type) |
|
def | get_meta (self) |
|
def | notify (self, status) |
|
def | thread_excepthook (self, text, exc) |
|
def | validate (self) |
|
def | close_batch (self) |
|
def | conditions_get_topics (self) |
|
def | conditions_register_message (self, topic, msg) |
|
def | conditions_set_topic_state (self, topic, pure) |
|
def | has_conditions (self) |
|
def | is_conditions_topic (self, topic, pure=True) |
|
Produces messages from iterable or pushed data.
Definition at line 1023 of file inputs.py.
def grepros.inputs.AppSource.__init__ |
( |
|
self, |
|
|
|
args = None , |
|
|
** |
kwargs |
|
) |
| |
@param args arguments as namespace or dictionary, case-insensitive;
or iterable yielding messages
@param args.topic ROS topics to read if not all
@param args.type ROS message types to read if not all
@param args.skip_topic ROS topics to skip
@param args.skip_type ROS message types to skip
@param args.start_time earliest timestamp of messages to read
@param args.end_time latest timestamp of messages to read
@param args.start_index message index within topic to start from
@param args.end_index message index within topic to stop at
@param args.unique emit messages that are unique in topic
@param args.select_field message fields to use for uniqueness if not all
@param args.noselect_field message fields to skip for uniqueness
@param args.nth_message read every Nth message in topic
@param args.nth_interval minimum time interval between messages in topic
@param args.condition Python expressions that must evaluate as true
for message to be processable, see ConditionMixin
@param args.iterable iterable yielding (topic, msg, stamp) or (topic, msg);
yielding `None` signals end of content
@param kwargs any and all arguments as keyword overrides, case-insensitive
Reimplemented from grepros.inputs.Source.
Definition at line 1032 of file inputs.py.