pipeline.h

Go to the documentation of this file.

#ifndef GRPPI_PIPELINE_H
#define GRPPI_PIPELINE_H

#include <utility>

#include "common/callable_traits.h"
#include "common/execution_traits.h"
#include "common/pipeline_pattern.h"

namespace grppi {

template <typename Execution, typename Generator, typename ... Transformers,
          requires_execution_supported<Execution> = 0>
void pipeline(
    const Execution & ex, 
    Generator && generate_op, 
    Transformers && ... transform_ops) 
{
  static_assert(supports_pipeline<Execution>(),
      "pipeline pattern is not supported by execution type");
  ex.pipeline(std::forward<Generator>(generate_op),
      std::forward<Transformers>(transform_ops)...);
}

template <typename Generator, typename ... Transformers, typename Consumer>
auto pipeline(
    Generator && generate_op,
    Transformers && ... transform_ops,
    Consumer && consume_op)
{
    return pipeline_t<Generator,Transformers...,Consumer> (
        std::forward<Generator>(generate_op),
        std::forward<Transformers>(transform_ops)...,
        std::forward<Consumer>(consume_op));
}
}

#endif