src/tools/benchmark_tool/benchmark_tool/output_formatter/generic_stream_formatter.py
def start_output_listener(self, topic, topic_datatype):
        """
        Start the subscriber on the specified topic.

        @param topic: The topic to listen for the data
        @type  topic: str
        @param topic_datatype: The data type of the topic
        @type  topic_datatype: Depends on the topic
        @return: True on success, False on failure
        """
        # Creates the results folder if not exists
        if not OutputFormatter.create_folder(self._result_path):
            return False

        try:
            # Subscribe to topic
            self.node.create_subscription(
                topic_datatype,
                topic,
                self._handle_callback,
                qos_profile=QoSProfile(depth=1)
            )
        except Exception as e:
            error(self.node, "%s" % str(e))
            return False

        # Remove everything inside that folder
        if not OutputFormatter.clean_folder(self._result_path):
            return False

        return True

        Start the subscriber on the specified topic.

        @param topic: The topic to listen for the data
        @type  topic: str
        @param topic_datatype: The data type of the topic
        @type  topic_datatype: Depends on the topic
        @return: True on success, False on failure
        
Start the subscriber on the specified topic.
Start the subscriber on the specified topic .
def start_output_listener(self, topic, topic_datatype):
        if not OutputFormatter.create_folder(self._result_path):
            return False
        try:
            self.node.create_subscription(
                topic_datatype,
                topic,
                self._handle_callback,
                qos_profile=QoSProfile(depth=1)
            )
        except Exception as e:
            error(self.node, "%s" % str(e))
            return False
        if not OutputFormatter.clean_folder(self._result_path):
            return False
        return True
def start_output_listener ( self , topic , topic_datatype ) : if not OutputFormatter . create_folder ( self . _result_path ) : return False try : self . node . create_subscription ( topic_datatype , topic , self . _handle_callback , qos_profile = QoSProfile ( depth = 1 ) ) except Exception as e : error ( self . node , "%s" % str ( e ) ) return False if not OutputFormatter . clean_folder ( self . _result_path ) : return False return True
Start the subscriber on the specified topic.
Start the subscriber on the specified topic .
"""
        Start the subscriber on the specified topic.

        @param topic: The topic to listen for the data
        @type  topic: str
        @param topic_datatype: The data type of the topic
        @type  topic_datatype: Depends on the topic
        @return: True on success, False on failure
        """ # Creates the results folder if not exists # Subscribe to topic # Remove everything inside that folder
True on success, False on failure
True on success False on failure
self
topic
The topic to listen for the data
The topic to listen for the data
topic_datatype
The data type of the topic
The data type of the topic