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_ */