File Coverage

blib/lib/Sub/Conveyor.pm

Criterion	Covered	Total	%
statement	46	46	100.0
branch	9	10	90.0
condition	1	3	33.3
subroutine	10	10	100.0
pod	4	4	100.0
total	70	73	95.8

package Sub::Conveyor;

use 5.006;
use strict;
use warnings;
our $VERSION = '0.03';

sub new {
	my ($self) = shift;
	$self = bless {
		conveyor => [ ]
	}, ref $self || $self;
	while (@_) {
		my ($type, $cb) = (shift, shift);
		$self->add(@{$type}, $cb);
	}
	return $self;
}

sub add {
	my ($self, @args) = @_;
	my $cb = pop @args;
	push @{$self->{conveyor}}, \@args, $cb;
}

sub call {
	my ($self, @params) = @_;
	my $len = scalar @{ $self->{conveyor} };
	for (my $i = 0; $i < $len; $i += 2) {
		my $conveyor_count = scalar @{ $self->{conveyor}->[$i] };
		if ( scalar @params == $conveyor_count ) {
			my $match = 1;
			for ( my $x = 0; $x < $conveyor_count; $x++ ) {
				eval {
					$self->{conveyor}->[$i]->[$x]->($params[$x])
				};
				if ($@) {
					$match = 0;
				}
			}
			if ($match) {
				@params = ($self->{conveyor}->[$i + 1]->(@params));
			}
		}
	}
	return wantarray ? @params : scalar @params == 1 ? $params[0] : \@params;
}

sub install {
	my ($self, $class, $method) = @_;
	no strict 'refs';
	no warnings 'redefine';
	*{"${class}::${method}"} = sub { shift; $self->call(@_) };
}

1;

__END__