File Coverage

blib/lib/POE/Filter/ThruPut.pm

Criterion	Covered	Total	%
statement	27	33	81.8
branch	2	4	50.0
condition			n/a
subroutine	9	11	81.8
pod	9	9	100.0
total	47	57	82.4

package POE::Filter::ThruPut;
$POE::Filter::ThruPut::VERSION = '1.00';
#ABSTRACT: a POE filter that passes data through unchanged whilst counting bytes sent and received

use strict;
use POE::Filter;
require bytes;

our @ISA = qw(POE::Filter);

sub new {
  my $type = shift;
  my $self = bless { buffer => '', in => 0, out => 0 }, $type;
  $self;
}

sub clone {
  my $self = shift;
  my $clone = bless { buffer => '', in => 0, out => 0 }, ref $self;
}

sub get_one_start {
  my ($self, $stream) = @_;
  my $dat = join '', @$stream;
  $self->{in} += bytes::length $dat;
  $self->{buffer} .= $dat;
}

sub get_one {
  my $self = shift;
  return [ ] unless CORE::length($self->{buffer});
  my $chunk = $self->{buffer};
  $self->{buffer}  = '';
  return [ $chunk ];
}

sub put {
  my ($self, $chunks) = @_;
  $self->{out} += bytes::length(join '', @$chunks);
  [ @$chunks ];
}

sub get_pending {
  my $self = shift;
  return undef if !CORE::length($self->{buffer});
  $self->{in} += bytes::length($self->{buffer});
  return [ $self->{buffer} ];
}

sub send {
  my $self = shift;
  return $self->{out};
}

sub recv {
  my $self = shift;
  return $self->{in};
}

sub stats {
  my $self = shift;
  return [ $self->{out}, $self->{in} ];
}

'Are you receiving?';

__END__