File Coverage

blib/lib/AnyEvent/HiveJSO.pm

Criterion	Covered	Total	%
statement	16	16	100.0
branch			n/a
condition			n/a
subroutine	6	6	100.0
pod			n/a
total	22	22	100.0

package AnyEvent::HiveJSO;
BEGIN {
  $AnyEvent::HiveJSO::AUTHORITY = 'cpan:GETTY';
}
# ABSTRACT: HiveJSO stream serializer/deserializer for AnyEvent
$AnyEvent::HiveJSO::VERSION = '0.002';
use strict;
use warnings;

use AnyEvent::Handle;
use HiveJSO;
use Carp qw( croak );

AnyEvent::Handle::register_write_type(hivejso => sub {
  my ($self, @args) = @_;
  return HiveJSO->new({ @args })->hivejso if scalar @args > 1;
  my $data = $args[0];
  my $ref = ref $data;
  if ($ref eq 'HASH') {
    return HiveJSO->new($data);
  } elsif ($ref eq 'ARRAY') {
    return HiveJSO->new({ @{$data} });
  } elsif ($data->can('hivejso')) {
    return $data->hivejso;
  }
  croak __PACKAGE__." can't handle this data with ref ".$ref;
});

AnyEvent::Handle::register_read_type(hivejso => sub {
  my ( $self, $cb ) = @_;
  sub {
    my ( $obj, $post ) = HiveJSO->parse_seek($_[0]{rbuf});
    if ($obj) {
      $_[0]{rbuf} = $post;
      $cb->( $_[0], $obj );
      return 1;
    }
    return 0;
  };
});

1;

__END__