54 lines
1.3 KiB
C++
54 lines
1.3 KiB
C++
#pragma once
|
|
#include <functional>
|
|
#include <utility>
|
|
#include <vector>
|
|
#include "esphome/core/log.h"
|
|
|
|
namespace esphome {
|
|
namespace ratgdo {
|
|
|
|
template <typename T>
|
|
class observable {
|
|
public:
|
|
observable(const T& value)
|
|
: value_(value)
|
|
{
|
|
}
|
|
|
|
template <typename U>
|
|
observable& operator=(U value)
|
|
{
|
|
if (value != this->value_) {
|
|
this->value_ = value;
|
|
this->notify();
|
|
}
|
|
return *this;
|
|
}
|
|
|
|
T const* operator&() const { return &this->value_; }
|
|
T const& operator*() const { return this->value_; }
|
|
|
|
template <typename Observer>
|
|
void subscribe(Observer&& observer)
|
|
{
|
|
this->observers_.push_back(std::forward<Observer>(observer));
|
|
ESP_LOGD("XXX","The observers vector is %d in length",this->observers_.size());
|
|
}
|
|
|
|
void notify() const
|
|
{
|
|
ESP_LOGD("YYY","NOTIFY %d subscribers",this->observers_.size());
|
|
|
|
for (const auto& observer : this->observers_) {
|
|
observer(this->value_);
|
|
}
|
|
}
|
|
|
|
private:
|
|
T value_;
|
|
std::vector<std::function<void(T)>> observers_;
|
|
};
|
|
|
|
} // namespace ratgdo
|
|
} // namespace esphome
|