source: src/EntityObserver_impl.hpp@ 75a0cb

/*
 * EntityObserver_impl.hpp
 *
 *  Created on: Dec 29, 2015
 *      Author: heber
 */


#ifndef ENTITYOBSERVER_IMPL_HPP_
#define ENTITYOBSERVER_IMPL_HPP_

// include config.h
#ifdef HAVE_CONFIG_H
#include <config.h>
#endif

#include <algorithm>

#include <boost/bind.hpp>

#include "CodePatterns/Observer/Channels.hpp"

/** Private constructor of class EntityObserver.
 *
 */
template <class T>
EntityObserver<T>::EntityObserver(
    const Observable::channels_t &_Channels,
    const std::string &_name) :
  Relay(_name),
  EntityChannels(_Channels)
{
  Channels *OurChannel = new Channels();
  Observable::insertNotificationChannel( std::make_pair(static_cast<Observable *>(this), OurChannel) );
  std::for_each(EntityChannels.begin(), EntityChannels.end(),
      boost::bind(&Channels::addChannel, OurChannel, _1));
}

/** Function to call when a new atom has been created.
 *
 * @param res
 */
template <class T>
void EntityObserver<T>::Inserted(Observable *res)
{
  ASSERT( dynamic_cast<Observable *>(res) != NULL,
      "EntityObserver<T>::Inserted - type is not derived from Observable.");
  std::for_each(EntityChannels.begin(), EntityChannels.end(),
      boost::bind(&Observable::signOn, res, this, _1, GlobalObservableInfo::PriorityDefault));
}

/** Function to call when an atom is about to get deleted.
 *
 * @param res
 */
template <class T>
void EntityObserver<T>::Removed(Observable *res)
{
  std::for_each(EntityChannels.begin(), EntityChannels.end(),
      boost::bind(&Observable::signOff, res, this, _1));
}

#endif /* ENTITYOBSERVER_IMPL_HPP_ */