File Coverage

blib/lib/Parallel/parallel_map.pm

Criterion	Covered	Total	%
statement	20	20	100.0
branch	4	4	100.0
condition			n/a
subroutine	6	6	100.0
pod	0	1	0.0
total	30	31	96.7

package Parallel::parallel_map;

use 5.008;
our $VERSION = '0.02';

use strict;
use warnings;
use Parallel::DataPipe;

require Exporter;

our @ISA = qw(Exporter);

our @EXPORT = qw(parallel_map);


sub parallel_map(&@) {
    my ($code,@input) = @_;
    my (@result,@output);
    if (wantarray) {
        @output = (output=>sub {my ($r,$i) = @_;$result[$i] = $r;});
    }
    Parallel::DataPipe::run {
        input => \@input,
        process => $code,
        @output,
    };
    return wantarray?@result:();
}

1;

__END__