valueproducer.h

Go to the documentation of this file.

#ifndef _value_producer_H_
#define _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() {}
 
  virtual const T& get() const { return output; }
 
  void connect_to(ValueConsumer<T>* consumer, uint8_t input_channel = 0) {
    this->attach([this, consumer, input_channel]() {
      consumer->set_input(this->get(), input_channel);
    });
  }
 
  template <typename CT>
  void connect_to(ValueConsumer<CT>* consumer, uint8_t input_channel = 0) {
    this->attach([this, consumer, input_channel]() {
      consumer->set_input(CT(this->get()), input_channel);
    });
  }
 
  template <typename T2>
  Transform<T, T2>* connect_to(Transform<T, T2>* consumer_producer,
                               uint8_t input_channel = 0) {
    this->attach([this, consumer_producer, input_channel]() {
      consumer_producer->set_input(T(this->get()), input_channel);
    });
    return consumer_producer;
  }
 
  template <typename TT, typename T2>
  Transform<TT, T2>* connect_to(Transform<TT, T2>* consumer_producer,
                                uint8_t input_channel = 0) {
    this->attach([this, consumer_producer, input_channel]() {
      consumer_producer->set_input(TT(this->get()), input_channel);
    });
    return consumer_producer;
  }
 
  /*
   * Set a new output value and notify consumers about it
   */
  void emit(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