dispatcher.hpp

Go to the documentation of this file.

 
#ifndef CORE_PROTOCOL_BASE_DISPATCHER_HPP
#define CORE_PROTOCOL_BASE_DISPATCHER_HPP
 
 
#include <functional>
#include <list>
 
namespace protocol {
  namespace base {
 
    template <typename... Args>
    class Dispatcher
    {
    public:
 
      using CbType = std::function<void(Args...)>;
 
      class CbId
      {
 
      public:
        CbId() : valid(false) {}
 
      private:
 
        friend class Dispatcher<Args...>;
 
        CbId(typename std::list<CbType>::iterator i)
 
          : iter(i), valid(true)
 
        {}
 
        typename std::list<CbType>::iterator iter;
        bool valid;
      };
 
      // register to be notified
      CbId addCB(CbType cb)
      {
        if (cb)
          {
            cbs.push_back(cb);
            return CbId(--cbs.end());
          }
 
        return CbId();
      }
 
      // unregister to be notified
      void delCB(CbId &id)
      {
        if (id.valid)
          {
            cbs.erase(id.iter);
          }
      }
 
      void broadcast(Args... args)
      {
        for (auto &cb : cbs)
          {
            cb(args...);
          }
      }
 
    private:
      std::list<CbType> cbs;
 
    };
 
  }
}
 
 
 
#endif