File Coverage

blib/lib/App/RecordStream/Stream/Base.pm

Criterion	Covered	Total	%
statement	21	21	100.0
branch			n/a
condition			n/a
subroutine	7	7	100.0
pod	0	4	0.0
total	28	32	87.5

package App::RecordStream::Stream::Base;

use JSON::MaybeXS;

use App::RecordStream::Record;
use App::RecordStream::OutputStream;

my $json = JSON->new;

sub new
{
  my $class = shift;

  my $this =
  {
  };

  bless $this, $class;

  return $this;
}

sub accept_record
{
  my $this = shift;
  my $record = shift;

  my $line = App::RecordStream::OutputStream::hashref_string($record);

  return $this->accept_line($line);
}

sub accept_line
{
  my $this = shift;
  my $line = shift;

  my $record = App::RecordStream::Record->new($json->decode($line));

  return $this->accept_record($record);
}

sub finish
{
}

1;