File Coverage

blib/lib/Mojo/UserAgent/Role/Queued/Queue.pm

Criterion	Covered	Total	%
statement	24	24	100.0
branch	2	2	100.0
condition	4	6	66.6
subroutine	6	6	100.0
pod	0	3	0.0
total	36	41	87.8

package Mojo::UserAgent::Role::Queued::Queue;

use strict;
use warnings;

use Mojo::Base 'Mojo::EventEmitter';

has jobs => sub { [] };
has active => 0;
has max_active => 4;
has callback => undef;


sub process {
   my ($self) = @_;
  # we have jobs and can run them:
  while ($self->active < $self->max_active
    and my $job = shift @{$self->jobs})
  {
    $self->active($self->active + 1);
    $self->callback->( @$job );
  }
  if (scalar @{$self->jobs} == 0 && $self->active == 0) {
    $self->emit('queue_empty');
  }
}

sub tx_finish {
    my ($self) = @_;
    $self->active($self->active - 1);
    $self->process();
}

sub enqueue {
    my ($self, $job) = @_;
    push @{$self->jobs}, $job;
    $self->process();
}

1;