example::my Namespace Reference

Variables
static auto	group_all_by
static auto	unique_all_by
static auto	where_min_by
static auto	where_max_by
static auto	lazy_transform_in_parallel
static auto	batched_lazy_transform_in_parallel

Variable Documentation

batched_lazy_transform_in_parallel

auto example::my::batched_lazy_transform_in_parallel

static

Initial value:

= [](auto fn,
                                                  size_t max_queue_size = std::thread::hardware_concurrency(),
                                                  size_t batch_size = 2)
{
    return [=](auto inputs)
    {
        return std::move(inputs)
      % fn::in_groups_of(batch_size)
      % my::lazy_transform_in_parallel( [&](auto inputs_batch)
        {
            return std::move(inputs_batch) 
                 % fn::transform(fn) 
                 % fn::to_vector(); 
                                    
                                    
        }, max_queue_size)
      % fn::concat(); 
    };
}

Definition at line 207 of file aln_filter.cpp.

group_all_by

auto example::my::group_all_by

static

Initial value:

= [](auto key_fn)
{
    return [key_fn = std::move(key_fn)](auto inputs)
    {
        return std::move(inputs)
      % fn::sort_by(key_fn)
      % fn::group_adjacent_by(key_fn);
    };
}

Definition at line 111 of file aln_filter.cpp.

lazy_transform_in_parallel

auto example::my::lazy_transform_in_parallel

static

Definition at line 159 of file aln_filter.cpp.

unique_all_by

auto example::my::unique_all_by

static

Initial value:

= [](auto key_fn)
{
    return [key_fn = std::move(key_fn)](auto inputs)
    {
        return std::move(inputs)
      % fn::sort_by(key_fn)
      % fn::unique_adjacent_by(key_fn);
    };
}

Definition at line 123 of file aln_filter.cpp.

where_max_by

auto example::my::where_max_by

static

Initial value:

= [](auto key_fn)
{   
    return my::where_min_by( fn::by::decreasing( std::move(key_fn)));
}

Definition at line 152 of file aln_filter.cpp.

where_min_by

auto example::my::where_min_by

static

Initial value:

= [](auto key_fn)
{
    return [key_fn = std::move(key_fn)](auto inputs)
    {
        
        return std::move(inputs) 
      % fn::sort_by(key_fn)      
                                 
                                 
      % fn::group_adjacent_by(key_fn)
      % fn::take_first(1)        
      % fn::concat();            
    };
}

Definition at line 135 of file aln_filter.cpp.