iteration_nodes.h

Go to the documentation of this file.

#ifndef GRPPI_FF_DETAIL_ITERATION_NODES_H
#define GRPPI_FF_DETAIL_ITERATION_NODES_H

#include <vector>

#include <ff/node.hpp>

namespace grppi {

namespace detail_ff {

template<typename Item, typename Iteration>
class iteration_worker : public ff::ff_node_t<Item> {
public:
  iteration_worker(Iteration && iteration) :
      iteration_{std::move(iteration)}
  {}

  Item * svc(Item * p_item) {
    do {
      *p_item = iteration_.transform(*p_item);
    }
    while (!iteration_.predicate(*p_item));
    return p_item;
  }

private:
  Iteration iteration_;
};

} // namespace detail_ff

} // namespace grppi

#endif