File Coverage

lib/Flux/Mapper/MappedMapper.pm

Criterion	Covered	Total	%
statement	11	16	68.7
branch	1	2	50.0
condition			n/a
subroutine	3	4	75.0
pod	0	3	0.0
total	15	25	60.0

package Flux::Mapper::MappedMapper;
{
  $Flux::Mapper::MappedMapper::VERSION = '1.03';
}

# ABSTRACT: representation of mapper|mapper


use Moo;
with 'Flux::Mapper';

has ['left', 'right'] => (
    is => 'ro',
    required => 1,
);

sub write {
    my ($self, $item) = @_;
    my @items = $self->left->write($item);
    my @result = map { $self->right->write($_) } @items;
    return (wantarray ? @result : $result[0]);
}

sub write_chunk {
    my ($self, $chunk) = @_;
    $chunk = $self->left->write_chunk($chunk);
    return $self->right->write_chunk($chunk);
}

sub commit {
    my ($self) = @_;
    my @items = $self->left->commit;
    my $result = $self->right->write_chunk(\@items);
    push @$result, $self->right->commit;
    return @$result;
}

1;

__END__