seq/stream_filter.h

Go to the documentation of this file.

#ifndef GRPPI_SEQ_STREAM_FILTER_H
#define GRPPI_SEQ_STREAM_FILTER_H

#include "sequential_execution.h"

namespace grppi {

template <typename Generator, typename Predicate, typename Consumer>
void keep(sequential_execution, Generator generate_op, 
          Predicate predicate_op, Consumer consume_op) 
{
  for (;;) {
    auto item = generate_op();
    if (!item) break;
    if (predicate_op(*item)) {
      consume_op(*item);
    }
  }
}

template <typename Generator, typename Predicate, typename Consumer>
void discard(sequential_execution & ex, Generator generate_op, 
             Predicate predicate_op, Consumer consume_op) 
{
  keep(ex, 
    std::forward<Generator>(generate_op), 
    [&](auto val) { return !predicate_op(val); },
    std::forward<Consumer>(consume_op) 
  );
}

}

#endif