readers_test_utils.hpp

#pragma once
 
#include "openev/containers/concurrent_queue.hpp"
#include "openev/containers/vector.hpp"
#include "openev/readers/abstract-reader.hpp"
 
static bool tryPull(ev::AbstractReader_ &reader, ev::Event &e) {
  ev::ConcurrentQueue *q = &reader.events();
  if(q->empty()) {
    q = &reader.events(1);
  }
  if(q->empty()) {
    return false;
  }
  e = q->front();
  q->pop();
  return true;
}
 
static ev::Vector drainAll(ev::AbstractReader_ &reader) {
  ev::Vector v;
  ev::Event e;
  while(tryPull(reader, e)) {
    v.push_back(e);
  }
  return v;
}