File Coverage

blib/lib/POE/Filter/MessagePack.pm

Criterion	Covered	Total	%
statement	35	39	89.7
branch	4	8	50.0
condition			n/a
subroutine	10	11	90.9
pod	5	5	100.0
total	54	63	85.7

package POE::Filter::MessagePack;
$POE::Filter::MessagePack::VERSION = '1.170412';
# ABSTRACT: A dead-simple POE::Filter for MessagePack
use strict;
use warnings;

use Data::MessagePack;
use Data::MessagePack::Stream;
use POE::Filter;

use vars qw($VERSION @ISA);
$VERSION = '1.001';
@ISA     = qw(POE::Filter);

sub MP ()     { 0 }
sub STREAM () { 1 }

sub new {
    my $type      = shift;
    my $mp        = Data::MessagePack->new;
    my $mp_stream = Data::MessagePack::Stream->new;

    my %opts = @_;

    $mp->prefer_integer if $opts{prefer_integer};
    $mp->canonical      if $opts{canonical};
    $mp->utf8           if $opts{utf8};

    my $self = bless [ $mp, $mp_stream ], $type;
    $self;
}

sub get {
    my ( $self, $chunks ) = @_;
    my @ret;
    push @ret, $self->[STREAM]->data while $self->[STREAM]->next;
    return \@ret;
}

sub get_one_start {
    my ( $self, $stream ) = @_;
    $self->[STREAM]->feed( join '', @$stream );
}

sub get_one {
    my $self = shift;
    my $obj  = $self->[STREAM]->next;
    return $obj ? [ $self->[STREAM]->data ] : [];
}

sub put {
    my ( $self, $chunks ) = @_;
    [ map { $self->[MP]->pack($_) } @$chunks ];
}

1;

__END__