Observable.h

Go to the documentation of this file.

 
#ifndef _SEUTILS_OBSERVABLE_H
#define _SEUTILS_OBSERVABLE_H
 
#include <memory>
#include <list>
 
namespace SourceXtractor {
 
template <class T>
class Observer {
public:
  virtual ~Observer() = default;
  virtual void handleMessage(const T& message) = 0;
};
 
template<class T>
class Observable {
 
public:
 
  virtual ~Observable() = default;
 
  virtual void addObserver(std::shared_ptr<Observer<T>> observer) {
    m_observers.push_back(observer);
  }
 
  virtual void removeObserver(std::shared_ptr<Observer<T>> observer) {
    m_observers.remove(observer);
  }
  
protected:
 
  // Notify all registered Observers with the given message
  void notifyObservers(const T& message) const {
    for (auto& observer : m_observers) {
      observer->handleMessage(message);
    }
  }
 
private:
  std::list<std::shared_ptr<Observer<T>>> m_observers;
 
}; /* End of Observable class */
 
} /* namespace SourceXtractor */
 
 
#endif