valueproducer.h

Go to the documentation of this file.

#ifndef SENSESP_SYSTEM_VALUE_PRODUCER_H_
#define SENSESP_SYSTEM_VALUE_PRODUCER_H_
 
#include <ArduinoJson.h>
 
#include "observable.h"
#include "valueconsumer.h"
 
namespace sensesp {
 
// The Transform class is defined in transforms/transform.h
template <typename C, typename P>
class Transform;
 
template <typename T>
class ValueProducer : virtual public Observable {
 public:
  ValueProducer() {}
  ValueProducer(const T& initial_value) : output(initial_value) {}
 
  virtual const T& get() const { return output; }
 
  void connect_to(ValueConsumer<T>* consumer) {
    this->attach([this, consumer]() { consumer->set(this->get()); });
  }
  void connect_to(ValueConsumer<T>& consumer) {
    this->attach([this, consumer]() { consumer.set(this->get()); });
  }
 
  template <typename CT>
  void connect_to(ValueConsumer<CT>* consumer) {
    this->attach([this, consumer]() { consumer->set(CT(this->get())); });
  }
  template <typename CT>
  void connect_to(ValueConsumer<CT>& consumer) {
    this->attach([this, consumer]() { consumer.set(CT(this->get())); });
  }
 
  template <typename T2>
  Transform<T, T2>* connect_to(Transform<T, T2>* consumer_producer) {
    this->attach([this, consumer_producer]() {
      consumer_producer->set(T(this->get()));
    });
    return consumer_producer;
  }
  template <typename T2>
  Transform<T, T2>* connect_to(Transform<T, T2>& consumer_producer) {
    this->attach(
        [this, consumer_producer]() { consumer_producer.set(T(this->get())); });
    return &consumer_producer;
  }
 
  template <typename TT, typename T2>
  Transform<TT, T2>* connect_to(Transform<TT, T2>* consumer_producer) {
    this->attach([this, consumer_producer]() {
      consumer_producer->set(TT(this->get()));
    });
    return consumer_producer;
  }
  template <typename TT, typename T2>
  Transform<TT, T2>* connect_to(Transform<TT, T2>& consumer_producer) {
    this->attach([this, consumer_producer]() {
      consumer_producer->set(TT(this->get()));
    });
    return &consumer_producer;
  }
 
  /*
   * Set a new output value and notify consumers about it
   */
  void emit(const T& new_value) {
    this->output = new_value;
    Observable::notify();
  }
 
 protected:
  T output;
};
 
typedef ValueProducer<float> FloatProducer;
typedef ValueProducer<int> IntProducer;
typedef ValueProducer<bool> BoolProducer;
typedef ValueProducer<String> StringProducer;
 
}  // namespace sensesp
 
#endif