seq/farm.h

Go to the documentation of this file.

#ifndef GRPPI_SEQ_FARM_H
#define GRPPI_SEQ_FARM_H

#include "sequential_execution.h"

namespace grppi {

template <typename Generator, typename Consumer>
void farm(sequential_execution ex, 
          Generator generate_op, Consumer consume_op) 
{
  for (;;) {
    auto item{generate_op()};
    if(!item) break;
    consume_op(*item);
  }
}

template <typename Generator, typename Transformer, typename Consumer>
void farm(sequential_execution ex, 
          Generator generate_op, Transformer transform_op, Consumer consume_op)
{
  for (;;) {
    auto item{generate_op()};
    if (!item) break;
    consume_op(transform_op(*item));
  }
}

}
#endif