File Coverage

lib/Flux/Mapper/MappedOut.pm

Criterion	Covered	Total	%
statement	8	18	44.4
branch			n/a
condition			n/a
subroutine	2	4	50.0
pod	0	3	0.0
total	10	25	40.0

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

# ABSTRACT: representation of mapper|out


use Moo;
with 'Flux::Out';

has 'mapper' => (
    is => 'ro',
    required => 1,
);

has 'out' => (
    is => 'ro',
    required => 1,
);

sub write {
    my $self = shift;
    my ($item) = @_;

    my @items = $self->mapper->write($item);
    $self->out->write($_) for @items;
    return;
}

sub write_chunk {
    my $self = shift;
    my ($chunk) = @_;

    $chunk = $self->mapper->write_chunk($chunk);
    $self->out->write_chunk($chunk);
    return;
}

sub commit {
    my ($self) = @_;

    my @items = $self->mapper->commit; # flushing the stuff remaining in possible mapper buffers
    $self->out->write_chunk(\@items);
    $self->out->commit;
    return;
}

1;

__END__