Observer.h

Go to the documentation of this file.

 
#ifndef SUPPORTLIB_OBSERVER_OBSERVABLE_H
#define SUPPORTLIB_OBSERVER_OBSERVABLE_H
#include "Object.h"
#include <vector>
#include <algorithm>
namespace giri {
    template <typename U>
    class Observer : public Object< Observer<U> >
    {
    public:
        virtual void update(std::shared_ptr<U> observable) = 0;
    protected:
        Observer() = default;
    };
 
    template <typename T>
    class Observable : public Object< Observable<T> >, public std::enable_shared_from_this<T>
    {
    public:
        void subscribe(const std::weak_ptr< Observer<T> >& obs){
            if(!obs.expired())
                m_Observers.push_back(obs);
        }
        void unsubscribe(const std::weak_ptr< Observer<T> >& obs){
            for(size_t i = 0; i < m_Observers.size(); i++)
                if(m_Observers[i].lock() == obs.lock()) {
                    m_Observers.erase(m_Observers.begin() + i);
                    break;
                }
        }
        void unsubscribeAll(){
            m_Observers.clear();
        }
        void notify(){
            for(const auto& curObs : m_Observers)
                curObs.lock()->update(this->shared_from_this());
        }
    protected:
        Observable() = default;
    private:
        std::vector< std::weak_ptr< Observer<T> > > m_Observers;
    };
}
#endif //SUPPORTLIB_OBSERVER_OBSERVABLE_H