File Coverage

blib/lib/List/Analyse/Sequence.pm

Criterion	Covered	Total	%
statement	7	9	77.7
branch			n/a
condition			n/a
subroutine	3	3	100.0
pod			n/a
total	10	12	83.3

package List::Analyse::Sequence;

use warnings;
use strict;

use Module::Pluggable (
    search      => [ "List::Analyse::Sequence::Analyser" ],
    sub_name    => 'analysers',
);
use List::MoreUtils qw(part);

our $VERSION = '0.01';

sub new {
    my $class   = shift;
    my $self    = bless {}, $class;

    return $self;
}

sub use_these_analysers {
    my $self    = shift;

    # Module::Pluggable does not give us the option of postponing
    # the require stage until we actually request the plugin be used.
    eval " CORE::require $_ " or warn $@ for @_;
    $self->{analysers} = [map {$_->new} @_];
}

sub analyse {
    my $self    = shift;
    my @data    = @_;

    $self->add( $_ ) for @data;
}

sub add {
    my $self    = shift;
    my $datum   = shift;

    $self->{discard} ||= [];

    my ($discarded_analysers, $remaining_analysers)
        = part { $_->analyse( $datum ) ? 1 : 0 } @{ $self->{analysers} };

    $discarded_analysers ||= []; $remaining_analysers ||= [];

    $self->{analysers} = $remaining_analysers;
    push @{ $self->{discard} }, @$discarded_analysers;
}

sub result {
    my $self    = shift;

    # Some analysers may be lazy or may need to wait.
    $_->done for @{$self->{analysers}};

    return ($self->{analysers}, $self->{discard}) if wantarray;
    return $self->{analysers};
}

1;
__END__