stream_reduce.h

Go to the documentation of this file.

#ifndef GRPPI_STREAM_REDUCE_H
#define GRPPI_STREAM_REDUCE_H

#include "common/patterns.h"

namespace grppi {

template <typename Identity, typename Combiner>
auto reduce(int window_size, int offset, 
                   Identity identity, 
                   Combiner && combine_op)
{
  return reduce_t<Combiner,Identity>(
       window_size, offset, identity, 
       std::forward<Combiner>(combine_op));
}

}

#endif