grppi/0.2/stream__filter_8h_source.html

 #ifndef GRPPI_STREAM_FILTER_H
 #define GRPPI_STREAM_FILTER_H

 #include "seq/stream_filter.h"
 #include "native/stream_filter.h"
 #include "omp/stream_filter.h"
 #include "tbb/stream_filter.h"
 #include "poly/stream_filter.h"

 #include "common/patterns.h"

 namespace grppi {

 template <typename Execution, typename Predicate>
 auto keep(Execution & ex, Predicate && predicate_op)
 {
   return filter_info<Execution, Predicate>{ex,
       std::forward<Predicate>(predicate_op)};
 }

 template <typename Execution, typename Predicate>
 auto discard(Execution & ex, Predicate && predicate_op)
 {
   return keep(ex, [&](auto val) { return !predicate_op(val); });
 }

 }

 #endif
grppi
Definition: callable_traits.h:24

grppi::filter_info
Definition: patterns.h:61

stream_filter.h

stream_filter.h

stream_filter.h

stream_filter.h

grppi::discard
void discard(parallel_execution_native &ex, Generator generate_op, Predicate predicate_op, Consumer consume_op)
Invoke Filter pattern on a data sequence with sequential execution policy. This function discards fro...
Definition: native/stream_filter.h:177

grppi::keep
void keep(parallel_execution_native &ex, Generator generate_op, Predicate predicate_op, Consumer consume_op)
Invoke Filter pattern pattern on a data sequence with sequential execution policy. This function keeps in the stream only those items that satisfy the predicate.
Definition: native/stream_filter.h:50

stream_filter.h

patterns.h