File Coverage

blib/lib/Net/Async/Tangence/Protocol.pm

Criterion	Covered	Total	%
statement	33	34	97.0
branch	7	8	87.5
condition	2	2	100.0
subroutine	9	9	100.0
pod	3	3	100.0
total	54	56	96.4

#  You may distribute under the terms of either the GNU General Public License
#  or the Artistic License (the same terms as Perl itself)
#
#  (C) Paul Evans, 2010-2011 -- [e-mail]

package Net::Async::Tangence::Protocol;

use strict;
use warnings;

our $VERSION = '0.13';

use base qw( IO::Async::Stream Tangence::Stream );

use Carp;

=head1 NAME

C - concrete implementation of
C for C

=head1 DESCRIPTION

This subclass of L provides a concrete implementation of
the L mixin. It is not intended to be directly used by
server implementations. Instead, it is subclassed as
L and L.

=cut

sub _init
{
   my $self = shift;
   my ( $params ) = @_;

   $self->SUPER::_init( $params );

   $params->{on_closed} ||= undef;
}

sub configure
{
   my $self = shift;
   my %params = @_;

   if( exists $params{on_closed} ) {
      my $on_closed = delete $params{on_closed};

      $params{on_closed} = sub {
         my ( $self ) = @_;
         $on_closed->( $self ) if $on_closed;

         $self->tangence_closed;

         if( my $parent = $self->parent ) {
            $parent->remove_child( $self );
         }
         elsif( my $loop = $self->get_loop ) {
            $loop->remove( $self );
         }
      };
   }

   $self->SUPER::configure( %params );
}

sub tangence_write
{
   my $self = shift;
   $self->write( $_[0] );
}

sub on_read
{
   my $self = shift;
   my ( $buffref, $closed ) = @_;

   $self->tangence_readfrom( $$buffref );

   return 0;
}

=head1 AUTHOR

Paul Evans

=cut

0x55AA;