subscriber.h

#ifndef B0__SUBSCRIBER_H__INCLUDED
#define B0__SUBSCRIBER_H__INCLUDED

#include <string>

#include <boost/function.hpp>
#include <boost/bind.hpp>

#include <b0/socket.h>

namespace b0
{

class Node;

class Subscriber : public Socket
{
public:
    using logger::LogInterface::log;

    Subscriber(Node *node, std::string topic_name, boost::function<void(const std::string&)> callback = 0, bool managed = true, bool notify_graph = true);

    template<class TNode>
    Subscriber(TNode *node, std::string topic_name, void (TNode::*callbackMethod)(const std::string&), bool managed = true, bool notify_graph = true)
        : Subscriber(node, topic_name, boost::bind(callbackMethod, node, _1), managed, notify_graph)
    {
        // delegate constructor. leave empty
    }

    template<class T>
    Subscriber(Node *node, std::string topic_name, void (T::*callbackMethod)(const std::string&), T *callbackObject, bool managed = true, bool notify_graph = true)
        : Subscriber(node, topic_name, boost::bind(callbackMethod, callbackObject, _1), managed, notify_graph)
    {
        // delegate constructor. leave empty
    }

    virtual ~Subscriber();

    void log(LogLevel level, std::string message) const override;

    virtual void init() override;

    virtual void cleanup() override;

    virtual void spinOnce() override;

    std::string getTopicName();

protected:
    virtual void connect();

    virtual void disconnect();

    const bool notify_graph_;

    boost::function<void(std::string&)> callback_;
};

} // namespace b0

#endif // B0__SUBSCRIBER_H__INCLUDED