subject.hpp

#pragma once
 
#include <vector>
 
#include "software/multithreading/observer.hpp"
 
template <typename T>
class Subject
{
   public:
    void registerObserver(std::shared_ptr<Observer<T>> observer);
 
    virtual ~Subject() = default;
 
   protected:
    virtual void sendValueToObservers(T val) final;
 
   private:
    // The observers that this class provides updates to
    std::vector<std::shared_ptr<Observer<T>>> observers;
};
 
template <typename T>
void Subject<T>::registerObserver(std::shared_ptr<Observer<T>> observer)
{
    observers.emplace_back(observer);
}
 
template <typename T>
void Subject<T>::sendValueToObservers(T val)
{
    for (std::shared_ptr<Observer<T>>& observer : observers)
    {
        observer->receiveValue(val);
    }
}