observable.hpp

Go to the documentation of this file.

//This file is part of Bertini 2.
//
//bertini2/detail/observable.hpp is free software: you can redistribute it and/or modify
//it under the terms of the GNU General Public License as published by
//the Free Software Foundation, either version 3 of the License, or
//(at your option) any later version.
//
//bertini2/detail/observable.hpp is distributed in the hope that it will be useful,
//but WITHOUT ANY WARRANTY; without even the implied warranty of
//MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//GNU General Public License for more details.
//
//You should have received a copy of the GNU General Public License
//along with bertini2/detail/observable.hpp.  If not, see <http://www.gnu.org/licenses/>.
//
// Copyright(C) 2015 - 2021 by Bertini2 Development Team
//
// See <http://www.gnu.org/licenses/> for a copy of the license, 
// as well as COPYING.  Bertini2 is provided with permitted 
// additional terms in the b2/licenses/ directory.
 
// individual authors of this file include:
// silviana amethyst, university of wisconsin-eau claire
//

 
#ifndef BERTINI_DETAIL_OBSERVABLE_HPP
#define BERTINI_DETAIL_OBSERVABLE_HPP
 
#include "bertini2/detail/observer.hpp"
#include "bertini2/detail/events.hpp"
 
namespace bertini{

    class Observable
    {   
    public:
 
        virtual ~Observable() = default;
 

        void AddObserver(AnyObserver& new_observer) const
        {
            if (find_if(begin(current_watchers_), end(current_watchers_), [&](const auto& held_obs)
                                          { return &held_obs.get() == &new_observer; })==end(current_watchers_))
                
                current_watchers_.push_back(std::ref(new_observer));
        }

        void RemoveObserver(AnyObserver& observer) const
        {
 
            auto new_end = std::remove_if(current_watchers_.begin(), current_watchers_.end(),
                                          [&](const auto& held_obs)
                                          { return &held_obs.get() == &observer; });
 
            current_watchers_.erase(new_end, current_watchers_.end());
 
 
            // current_watchers_.erase(std::remove(current_watchers_.begin(), current_watchers_.end(), std::ref(observer)), current_watchers_.end());
        }
 
    protected:

        void NotifyObservers(AnyEvent const& e) const
        {
 
            for (auto& obs : current_watchers_)
                obs.get().Observe(e);
 
        }
 
        void NotifyObservers(AnyEvent & e) const
        {
 
            for (auto& obs : current_watchers_)
                obs.get().Observe(e);
        }
 
 
    private:
 
        using ObserverContainer = std::vector<std::reference_wrapper<AnyObserver>>;
 
        mutable ObserverContainer current_watchers_;
    };
 
} // namespace bertini
 
 
#endif