stateSubscriber.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_STATESUBSCRIBER_HPP
#define RTCTK_COMPONENTFRAMEWORK_STATESUBSCRIBER_HPP
 
#include <mal/utility/Uri.hpp>
#include <taiclock/taiClock.hpp>
 
#include <functional>
#include <memory>
#include <vector>
 
namespace elt::mal::ps {
template <typename TOPIC_TYPE>
class Subscriber;
 
class Subscription;
}  // namespace elt::mal::ps
 
namespace stdif {
class State;
}
 
namespace rtctk::componentFramework {

class StateSubscriber {
public:
    using Callback = std::function<void(const taiclock::TaiClock::time_point time,
                                        const std::string& name,
                                        const std::string& state)>;
 
    StateSubscriber(const elt::mal::Uri& uri, Callback on_state_change);
    StateSubscriber(const std::vector<elt::mal::Uri>& uri_list, Callback on_state_change);
 
    // no copy allowed
    StateSubscriber(const StateSubscriber& other) = delete;
    StateSubscriber& operator=(const StateSubscriber& other) = delete;
 
    // move it instead
    StateSubscriber(StateSubscriber&& other) = default;
    StateSubscriber& operator=(StateSubscriber&& other) = default;
 
    virtual ~StateSubscriber() = default;
 
private:
    // cppcheck-suppress-begin unusedStructMember
 
    std::vector<std::unique_ptr<elt::mal::ps::Subscriber<stdif::State>>> m_subscribers;
    std::vector<std::unique_ptr<elt::mal::ps::Subscription>> m_subscriptions;
 
    // cppcheck-suppress-end unusedStructMember
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_STATESUBSCRIBER_HPP