include/vrvCore/DtSubjectObserver.h

Go to the documentation of this file.

/****************************************************************************** 
** Copyright (c) 2010 MAK Technologies, Inc. 
** All rights reserved. 
******************************************************************************/ 
 
 
#pragma once
 
#include <vrvCore/vrvCore.h> 
#include <vrvCore/DtDe.h> 
#include <vrvCore/DtSubjectAnnouncer.h> 
#include <vrvCore/DtSubjectBinder.h>

#include <vrvUtil/templateUtil.h>

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

namespace makVrv 
{ 

   template<class T>
   class DtSubjectObserver : public virtual DtSubjectBinder
   { 

   public:

      DtSubjectObserver();

      virtual ~DtSubjectObserver();

      virtual void slot_activate(T* subject) = 0;

      virtual void slot_deactivate(T* subject) = 0;

   protected:

      virtual void connect(DtDe& de);


   }; 

   template<class T>
   DtSubjectObserver<T>::DtSubjectObserver()
   {
      BindFunction functor =  boost::bind(&DtSubjectObserver<T>::connect, this, _1);

      myBindFunctionList.push_back(functor);
   }

   template<class T>
   DtSubjectObserver<T>::~DtSubjectObserver()
   {

   }

   template<class T>
   void DtSubjectObserver<T>::connect( DtDe& de )
   {
      DtSubjectAnnouncer<T>* announcer = DtSubjectAnnouncer<T>::findInstance(de);

      if(announcer)
      {
         announcer->signal_activate.connect(
            boost::bind(&DtSubjectObserver<T>::slot_activate, this, _1));

         // w/ each activated subject instance.
         typename std::list<T*>::iterator curIter = announcer->activatedList().begin();
         typename std::list<T*>::iterator endIter = announcer->activatedList().end();
         for(;curIter != endIter; ++curIter)
         {
            this->slot_activate(*curIter);
         }
      }
   }

   EXPORT_TEMPLATE_TYPEDEF(DtSubjectObserver<DtDe>, DtDeObserver)
   EXPORT_TEMPLATE_TYPEDEF(DtSubjectObserver<DtDisplay>, DtDisplayObserver)
   EXPORT_TEMPLATE_TYPEDEF(DtSubjectObserver<DtDeCommunicator>, DtDeCommunicatorObserver)
}