view release on metacpan or  search on metacpan

lib/AWS/XRay/Buffer.pm  view on Meta::CPAN

        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;