File Coverage

blib/lib/AnyEvent/MessagePack.pm

Criterion	Covered	Total	%
statement	18	18	100.0
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod			n/a
total	24	24	100.0

package AnyEvent::MessagePack;
use strict;
use warnings;
use 5.010001;
our $VERSION = '0.19';

use AnyEvent::Handle;

use Data::MessagePack 0.34;
use Data::MessagePack::Stream 0.05;

AnyEvent::Handle::register_write_type(msgpack => sub {
    my ($self, $data) = @_;
    Data::MessagePack->pack($data);
});

AnyEvent::Handle::register_read_type(msgpack => sub {
    my ($self, $cb) = @_;

    # FIXME This implementation eats all the data, so the stream may
    # contain only MessagePack packets.

    my $unpacker = $self->{_msgpack} ||= Data::MessagePack::Stream::->new;

    sub {
        my $buffer = delete $_[0]{rbuf};

        $unpacker->feed($buffer) if defined $buffer;

        if ($unpacker->next) {
            $cb->( $_[0], $unpacker->data );
            return 1;
        }
        return 0;
    }
});

1;
__END__