3 from flexbe_core
import EventState
6 from std_msgs.msg
import String
12 super(TestSubState, self).
__init__(outcomes=[
'received',
'unavailable'],
13 output_keys=[
'output_value'])
17 self.
_timeout = rospy.Time.now() + rospy.Duration(1.5)
22 userdata.output_value =
None 25 if self._sub.has_msg(self.
_topic):
26 msg = self._sub.get_last_msg(self.
_topic)
27 self._sub.remove_last_msg(self.
_topic)
28 userdata.output_value = msg.data
def execute(self, userdata)
def __init__(self, topic)