File Coverage

blib/lib/Data/Pipeline/Action/Count.pm

Criterion	Covered	Total	%
statement	1	3	33.3
branch			n/a
condition			n/a
subroutine	1	1	100.0
pod			n/a
total	2	4	50.0

package Data::Pipeline::Action::Count;

use Moose;
with 'Data::Pipeline::Action';

has name => (
    isa => 'Str',
    is => 'rw',
    lazy => 1,
    default => 'count'
);

sub reduce_iterator {
    my($self, $iterator) = @_;

#    print STDERR "iterator: $iterator\n";
    my $count = 0;
    until( $iterator -> finished ) { $iterator -> next; $count++; } #print STDERR "count: ", $iterator -> next, "\n"; $count++; }
    return {
        $self -> name => $count
    };
}

sub meta_reduce {
    my($self, $iterator) = @_;

    my $count = 0;
    $count += $iterator -> next -> {$self -> name} until $iterator -> finished;
    return {
        $self -> name => $count
    };
}

1;

__END__