#!/usr/bin/perl -w
# vim: ts=2 sw=2 filetype=perl expandtab

# Exercises Filter::Stream without the rest of POE.

use strict;
use lib qw(./mylib ../mylib);
use lib qw(t/10_units/05_filters);

use TestFilter;
use Test::More tests => 9 + $COUNT_FILTER_INTERFACE + $COUNT_FILTER_STANDARD;

sub POE::Kernel::ASSERT_DEFAULT () { 1 }

BEGIN {
  package POE::Kernel;
  use constant TRACE_DEFAULT => exists($INC{'Devel/Cover.pm'});
}

use_ok("POE::Filter::Stream");
test_filter_interface("POE::Filter::Stream");

my $filter = POE::Filter::Stream->new;
isa_ok($filter, 'POE::Filter::Stream');
my @test_fodder = qw(a bc def ghij klmno);

# General test
test_filter_standard(
  $filter,
  [qw(a bc def ghij klmno)],
  [qw(abcdefghijklmno)],
  [qw(abcdefghijklmno)],
);

# Specific tests for stream filter
{ my $received = $filter->get( \@test_fodder );
  ok(
    eq_array($received, [ 'abcdefghijklmno' ]),
    "received combined test items"
  );
}

{ my $sent = $filter->put( \@test_fodder );
  ok(
    eq_array($sent, \@test_fodder),
    "sent each item discretely"
  );
}

{ $filter->get_one_start( \@test_fodder );
  pass("get_one_start didn't die or anything");
}

{ my $pending = $filter->get_pending();
  ok(
    eq_array($pending, [ 'abcdefghijklmno' ]),
    "pending data is correct"
  );
}

{ my $received = $filter->get_one();
  ok(
    eq_array($received, [ 'abcdefghijklmno' ]),
    "get_one() got the right one, baby, uh-huh"
  );
}

{ my $received = $filter->get_one();
  ok(
    eq_array($received, [ ]),
    "get_one() returned an empty array on empty buffer"
  );
}

{ my $pending = $filter->get_pending();
  ok(!defined($pending), "pending data is empty");
}


exit;