abstract-reader.hpp

 
#ifndef OPENEV_READERS_ABSTRACT_READER_HPP
#define OPENEV_READERS_ABSTRACT_READER_HPP
 
#include "openev/containers/array.hpp"
#include "openev/containers/queue.hpp"
#include "openev/containers/vector.hpp"
#include "openev/core/types.hpp"
#include <cstddef>
 
namespace ev {
 
class AbstractReader_ {
public:
  AbstractReader_() = default;
  virtual ~AbstractReader_() = default;
  AbstractReader_(const AbstractReader_ &) = delete;
  AbstractReader_(AbstractReader_ &&) noexcept = delete;
  AbstractReader_ &operator=(const AbstractReader_ &) = delete;
  AbstractReader_ &operator=(AbstractReader_ &&) noexcept = delete;
  inline bool next(Event &e) {
    return read_(e);
  }
 
  template <std::size_t N>
  bool next(Array<N> &array) {
    for(Event &a : array) {
      if(!read_(a)) {
        return false;
      }
    }
    return true;
  }
 
  bool next_n(Vector &vector, const int n);
 
  bool next_n(Queue &queue, const int n, const bool keep_size = false);
 
  bool next_t(Vector &vector, const double t);
 
  bool next_t(Queue &queue, const double t, const bool keep_size = false);
 
  bool skip_n(int n);
 
  bool skip_t(const double t);
 
  inline void reset() {
    return reset_();
  }
 
  std::size_t count() {
    std::size_t cnt = 0;
    reset_();
    while(skip_n(1)) {
      cnt++;
    }
    reset_();
    return cnt;
  }
 
protected:
  virtual bool read_(Event &e) = 0;
  virtual void reset_() = 0;
};
 
} // namespace ev
 
#endif // OPENEV_READERS_ABSTRACT_READER_HPP