File Coverage

blib/lib/Flow/Splice.pm

Criterion	Covered	Total	%
statement	15	45	33.3
branch	0	8	0.0
condition	0	3	0.0
subroutine	5	10	50.0
pod	0	5	0.0
total	20	71	28.1

#===============================================================================
#
#  DESCRIPTION:  Splice flow
#
#       AUTHOR:  Aliaksandr P. Zahatski,
#===============================================================================
#$Id$

=head1 NAME

Flow::Splice - Stream breakdown on a parts

=head1 SYNOPSIS

    my $f1 = Flow::create_flow(
        Splice => 200 );
    $f1->run( 1, 3, 11 );

=cut

package Flow::Splice;
use warnings;
use strict;
use Data::Dumper;
use Flow;
use base 'Flow';

sub new {
    my $class = shift;
    my $count = shift;
    my $self  = $class->SUPER::new(@_);
    $self->{stack}   = [];
    $self->{_Splice} = $count;
    return $self;

}

sub purge_stack {
    my $self  = shift;
    my $stack = $self->{stack};
    my $res;
    if ( scalar(@$stack) ) {
        $res    = $self->put_flow(@$stack);
        @$stack = ();
    }
    $res    #return put_flow res
}

sub ctl_flow {
    my $self  = shift;
    my $state = $self->purge_stack();
    return $state || $self->SUPER::ctl_flow(@_);
}

sub flow {
    my $self  = shift;
    my $stack = $self->{stack};
    my $count = $self->{_Splice};
    foreach my $r (@_) {
        if ( @$stack >= $count ) {
            if ( my $status = $self->purge_stack() ) { return $status }
        }
        push @$stack, $r;
    }
    return undef;
}

sub end {
    my $self  = shift;
    my $stack = $self->{stack};
    if ( my $status = $self->purge_stack() ) { return $status }
    return \@_;
}

1;

__END__