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 <vector>
#include <memory>
#include <functional>
 
namespace elt::mal::ps {
    template <typename TOPIC_TYPE>
    class Subscriber;
 
    class Subscription;
}
 
namespace stdif {
    class State;
}
 
namespace rtctk::componentFramework  {
 
    class StateSubscriber {
    public:
        using Callback = std::function<void(double 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:
        std::vector<std::unique_ptr<elt::mal::ps::Subscriber<stdif::State>>> m_subscribers;
        std::vector<std::unique_ptr<elt::mal::ps::Subscription>> m_subscriptions;
    };
}
 
#endif