throttle.h

Go to the documentation of this file.

#ifndef SENSESP_SRC_SENSESP_TRANSFORMS_THROTTLE_H_
#define SENSESP_SRC_SENSESP_TRANSFORMS_THROTTLE_H_
 
#include <climits>
#include <elapsedMillis.h>
 
#include "transform.h"
 
namespace sensesp {
 
template <typename T>
class Throttle : public SymmetricTransform<T> {
 public:
  Throttle(long min_interval)
      : SymmetricTransform<T>(), min_interval_{min_interval} {}
 
  void set(const T& input) override {
    if (age_ < min_interval_) {
      return;
    }
    age_ = 0;
    this->emit(input);
  }
 
 protected:
  long min_interval_;
  elapsedMillis age_ = LONG_MAX;
};
 
}  // namespace sensesp
 
#endif  // SENSESP_SRC_SENSESP_TRANSFORMS_THROTTLE_H_