observeConnection.h

Go to the documentation of this file.

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


#ifndef observeConnection_H_
#define observeConnection_H_

#include "lgrUtil.h"

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

namespace MAKLogger
{

   template <typename SubjectType>
   class DtObserveEvent;

   template <typename SubjectType>
   class DtObserver;

   class DtObserveConnection;
   typedef std::shared_ptr<DtObserveConnection> DtObserveConnectionSP;

   class DtObserveConnectionComponent;


   class DT_DLL_LGRUTIL DtObserveConnection
   {
   public:

      template <typename SubjectType>
      static void connect(DtObserveEvent<SubjectType>* event,
         DtObserver<SubjectType>* observer)
      {
         if(event->isConnected(observer)) return;
         DtObserveConnection* connection =
            new DtObserveConnection(event,observer);
         DtObserveConnectionSP sharedCon(connection);
         event->connect(sharedCon);
         observer->connect(sharedCon);
      }

      void disconnect(DtObserveConnectionSP);

      DtObserveConnectionComponent* event();

      DtObserveConnectionComponent* observer();

   protected:

      DtObserveConnection(DtObserveConnectionComponent* event,DtObserveConnectionComponent* observer);

      DtObserveConnectionComponent* myEvent;

      DtObserveConnectionComponent* myObserver;
   };

   class DT_DLL_LGRUTIL DtObserveConnectionComponent
   {
   public:

      typedef std::list<DtObserveConnectionSP> ConnectionList;

      virtual ~DtObserveConnectionComponent();

      virtual void connect(DtObserveConnectionSP con);

      virtual void disconnect(DtObserveConnectionSP con);

      virtual void disconnect(DtObserveConnectionComponent* component);

      virtual bool isConnected(DtObserveConnectionComponent* component);

      void disconnectAll();

   protected:

      DtObserveConnectionComponent();

      DtObserveConnectionComponent(const DtObserveConnectionComponent&);

      DtObserveConnectionComponent& operator=(
         const DtObserveConnectionComponent&);

      DtObserveConnectionSP findEventObserverConnection(
         DtObserveConnectionComponent* event,
         DtObserveConnectionComponent* observer);

      ConnectionList myConnections;
   };

}

#endif