moveit_studio::behaviors::RclcppSubscriberInterface< MessageT > Class Template Reference

Implementation of the subscriber interface for a rclcpp subscription. More...

#include <get_message_from_topic.hpp>

Inheritance diagram for moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >:

Collaboration diagram for moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >:

Public Member Functions
	RclcppSubscriberInterface (const std::shared_ptr< BehaviorContext > &shared_resources)
tl::expected< void, std::string >	initialize (const std::string &topic_name, const std::chrono::duration< double > &wait_for_message_timeout, const std::chrono::duration< double > &wait_for_publisher_timeout) override
	Initializes the rclcpp subscriber interface to listen on the provided topic.
tl::expected< void, std::string >	initialize (const std::string &topic_name, const std::chrono::duration< double > &wait_for_message_timeout, const std::chrono::duration< double > &wait_for_publisher_timeout, std::optional< std::function< void()> > on_haltable)
	An overloaded form of initialize with an additional callback parameter that is called when the current task can be halted.
tl::expected< MessageT, std::string >	syncGetNextMessage () override
	Block until a message is received on the topic.
void	halt () override
	Stops any publisher or message checking.
Public Member Functions inherited from moveit_studio::behaviors::GetMessageFromTopicBehaviorBase< MessageT >::SubscriberInterfaceBase
virtual	~SubscriberInterfaceBase ()=default

Detailed Description

template<typename MessageT>
class moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >

Implementation of the subscriber interface for a rclcpp subscription.

Constructor & Destructor Documentation

RclcppSubscriberInterface()

template<typename MessageT >

moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >::RclcppSubscriberInterface ( const std::shared_ptr< BehaviorContext > &  shared_resources )

explicit

Member Function Documentation

halt()

template<typename MessageT >

void moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >::halt ( )

overridevirtual

Stops any publisher or message checking.

Implements moveit_studio::behaviors::GetMessageFromTopicBehaviorBase< MessageT >::SubscriberInterfaceBase.

initialize() [1/2]

template<typename MessageT >

tl::expected< void, std::string > moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >::initialize ( const std::string &  topic_name, const std::chrono::duration< double > &  wait_for_message_timeout, const std::chrono::duration< double > &  wait_for_publisher_timeout  )

overridevirtual

Initializes the rclcpp subscriber interface to listen on the provided topic.

This blocks for a brief duration until a publisher is available on the topic. If no publisher appears before the timeout, returns an error result.

After the publisher appears, get its current QoS settings, and set the subscriber's QoS settings to have the same reliability setting as the publisher. This ensures that the subscriber QoS always matches the publisher in situations where the same behavior may need to get messages from different sources which use different QoS settings (for example, retrieving images from a simulated camera publisher vs. a real-hardware camera driver).

Parameters

topic_name	The topic name to use when creating the subscriber.
wait_for_message_timeout	The timeout duration to use when waiting for a message to be received on the topic.
wait_for_publisher_timeout	The timeout duration to use when waiting for a publisher to advertise on the topic.

Returns

Void if the subscriber interface was initialized successfully. Returns an error result if no publisher appeared on the topic or the subscriber could not be created.

Implements moveit_studio::behaviors::GetMessageFromTopicBehaviorBase< MessageT >::SubscriberInterfaceBase.

initialize() [2/2]

template<typename MessageT >

tl::expected< void, std::string > moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >::initialize	(	const std::string &	topic_name,
		const std::chrono::duration< double > &	wait_for_message_timeout,
		const std::chrono::duration< double > &	wait_for_publisher_timeout,
		std::optional< std::function< void()> >	on_haltable
	)

An overloaded form of initialize with an additional callback parameter that is called when the current task can be halted.

syncGetNextMessage()

template<typename MessageT >

tl::expected< MessageT, std::string > moveit_studio::behaviors::RclcppSubscriberInterface< MessageT >::syncGetNextMessage ( )

overridevirtual

Block until a message is received on the topic.

Returns

If the message was received, returns the message. Returns an error result if the timeout duration was exceeded before a message was received.

Implements moveit_studio::behaviors::GetMessageFromTopicBehaviorBase< MessageT >::SubscriberInterfaceBase.

---

The documentation for this class was generated from the following files:

• get_message_from_topic.hpp
• get_message_from_topic_impl.hpp