File Coverage

blib/lib/AWS/XRay/Buffer.pm

Criterion	Covered	Total	%
statement	27	27	100.0
branch	2	2	100.0
condition			n/a
subroutine	7	7	100.0
pod	0	4	0.0
total	36	40	90.0

package AWS::XRay::Buffer;

use 5.012000;
use strict;
use warnings;

sub new {
    my $class = shift;
    my ($sock, $auto_flush) = @_;
    bless {
        buf        => [],
        sock       => $sock,
        auto_flush => $auto_flush,
    }, $class;
}

sub flush {
    my $self = shift;
    my $sock = $self->{sock};
    for my $buf (@{$self->{buf}}) {
        $sock->syswrite($buf, length($buf));
    }
    $self->{buf} = [];
    1;
}

sub close {
    my $self = shift;
    $self->{buf} = [];
    1;
}

sub print {
    my $self = shift;
    my $data = join("", @_);
    if ($self->{auto_flush}) {
        $self->{sock}->syswrite($data, length($data));
    }
    else {
        push @{$self->{buf}}, $data;
    }
}

1;