observeEvent.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2025 MAK Technologies, Inc
** All rights reserved.
******************************************************************************/


#ifndef observeEvent_H_
#define observeEvent_H_

#include <list>
#include <algorithm>
#include <vlutil/vlSmartPointers.h>

#include <vlutil/vlExceptions.h>
#include "observeConnection.h"
#include <lgrUtil/observe.h>

namespace MAKLogger
{

   template<typename SubjectType>
   class DtObserveEvent : public DtObserveConnectionComponent
   {

   public:
      typedef DtObserver<SubjectType> SubjectObserver;
      typedef std::list<DtObserver<SubjectType>*> ObserverList;

      DtObserveEvent() :
         myObservers()
      {
      }

      virtual ~DtObserveEvent()
      {
      }

      virtual void connect(DtObserveConnectionSP con)
      {
         if(!con)
         {
            throw DtInvalidInput("Connection may not be null.");
         }
         DtObserveConnectionComponent::connect(con);
         SubjectObserver* observer = reinterpret_cast<SubjectObserver*>
            (con->observer());
         typename ObserverList::iterator it;
         it = std::find(myObservers.begin(),myObservers.end(),observer);
         if(it == myObservers.end())
         {
            myObservers.push_back(observer);
         }
      }



      virtual void disconnect(DtObserveConnectionSP con)
      {
         if(!con)
         {
            throw DtInvalidInput("Connection may not be null.");
         }
         DtObserveConnectionComponent::disconnect(con);
         SubjectObserver* observer = reinterpret_cast<SubjectObserver*>
            (con->observer());
         myObservers.remove(observer);
      }

      virtual void disconnect(SubjectObserver* observer)
      {
         DtObserveConnectionSP sharedCon = findEventObserverConnection(this,
            reinterpret_cast<DtObserveConnectionComponent*>(observer));
         if(sharedCon)
         {
            sharedCon->disconnect(sharedCon);
         }
      }

      void observeSubject(const SubjectType& value)
      {
         typename ObserverList::iterator obs;
         obs = myObservers.begin();
         for(;obs != myObservers.end();++obs)
         {
            (*obs)->observe(value);
         }
      }

   protected:

      ObserverList myObservers;
   };

}

#endif