File Coverage

blib/lib/XML/SAX/ExpatNB.pm

Criterion	Covered	Total	%
statement	3	3	100.0
branch			n/a
condition			n/a
subroutine	1	1	100.0
pod			n/a
total	4	4	100.0

#!/usr/bin/perl -w

package XML::SAX::ExpatNB;
use base qw/XML::SAX::Expat::Incremental/;

use strict;
#use warnings;

use vars qw/$VERSION/;
$VERSION = "0.01";

use IO::Handle ();
use Scalar::Util qw/blessed/;
use Carp qw/croak/;

sub parse {
	my $p = shift;
	my $opts = $p->get_options(@_);

	if ($p->{Parent}){
		return $p->{Parent}->parse($opts);
	} else {
		if (defined $opts->{Source}{ByteStream}){
			if ($opts->{ReadOnce}){
				return $p->_parse_bytestream_once($opts->{Source}{ByteStream}, $opts->{ReadOnce});
			} else {
				return $p->_parse_bytestream($opts->{Source}{ByteStream});
			}
		} else {
			croak "Nonblocking reads only make sense if you're giving me file handles, y'know (well, actually sockets). Use parse_file";
		}
	}
}

sub parse_once {
	my $p = shift;
	my $fh = shift;
	my $bytes = shift || 4096;
	$p->parse_file($fh, @_, ReadOnce => $bytes);
}

sub _parse_bytestream {
	my $p = shift;
	my $fh = shift;
	$fh = IO::Handle->new_from_fd($fh, "<") unless blessed $fh;

	$fh->blocking(0);

	while($fh->sysread(my $buffer, 4096)){
		$p->_parse_string($buffer);
	}
}

sub _parse_bytestream_once {
	my $p = shift;
	my $fh = shift;
	$fh = IO::Handle->new_from_fd($fh, "<") unless blessed $fh;
	my $bytes = shift;

	$fh->blocking(0);

	my $buffer;
	$fh->sysread($buffer, $bytes)
		and $p->_parse_string($buffer);
}

__PACKAGE__

__END__