topic.hpp

Go to the documentation of this file.

/*****************************************************************************
** Ifdefs
*****************************************************************************/

#ifndef ECL_SIGSLOTS_TOPIC_HPP_
#define ECL_SIGSLOTS_TOPIC_HPP_

/*****************************************************************************
** Includes
*****************************************************************************/

#include <string>
#include <set>
#include <ecl/config/macros.hpp>

/*****************************************************************************
** Namespaces
*****************************************************************************/

namespace ecl {

/*****************************************************************************
** Forward Declarations
*****************************************************************************/

template <typename Data>
class SigSlot;

/*****************************************************************************
** Interface
*****************************************************************************/
template <typename Data>
class ECL_LOCAL Topic {
public:
        /*********************
        ** Typedefs
        **********************/
        typedef std::set<SigSlot<Data>*> Subscribers;  
        Topic(const std::string& name) : topic_name(name) {}

        const Subscribers* subscribers() const { return &topic_subscribers; }

        void addSubscriber(SigSlot<Data>* sigslot) {
                topic_subscribers.insert(sigslot);
        }
        void addPublisher(SigSlot<Data>* sigslot) {
                topic_publishers.insert(sigslot);
        }
        void disconnect(SigSlot<Data>* sigslot) {
                typename std::set<SigSlot<Data>*>::const_iterator iter = topic_publishers.find(sigslot);
                if ( iter != topic_publishers.end() ) {
                        topic_publishers.erase(iter);
                }
                iter = topic_subscribers.find(sigslot);
                if ( iter != topic_subscribers.end() ) {
                        topic_subscribers.erase(iter);
                }
        }
        bool empty() const {
                return ( ( topic_publishers.size() == 0 ) && ( topic_subscribers.size() == 0 ) );
        }

    /*********************
    ** Streaming
    **********************/
    template <typename OutputStream, typename TopicData>
    friend OutputStream& operator<<(OutputStream &ostream , const Topic<TopicData>& topic);

private:
    std::string topic_name;
    std::set<SigSlot<Data>*> topic_publishers;
    std::set<SigSlot<Data>*> topic_subscribers;
};


/*****************************************************************************
** Implementation [Streaming]
*****************************************************************************/

template <typename OutputStream, typename TopicData>
OutputStream& operator<<(OutputStream &ostream , const Topic<TopicData> &topic) {

        ostream << "  Name: " << topic.topic_name << "\n";
        ostream << "    # Subscribers: " << topic.topic_subscribers.size() << "\n";
        ostream << "    # Publishers : " << topic.topic_publishers.size() << "\n";
    ostream.flush();

    return ostream;
}

} // namespace ecl

#endif /* ECL_SIGSLOTS_TOPIC_HPP_ */