| blib/lib/Job/Async/Worker/Memory.pm | |||
|---|---|---|---|
| Criterion | Covered | Total | % |
| condition | 1 | 3 | 33.3 |
| line | l | !l&&r | !l&&!r | condition |
|---|---|---|---|---|
| 40 | 0 | 2 | 0 | $self->{'active'} ||= &repeat(sub { my $loop = $self->loop; my $f = $loop->new_future; $self->loop->later(sub { if (my $job = shift @Job::Async::Memory::PENDING_JOBS) { $self->process($job); } ; $f->done; } ); $f; } , 'while', sub { 0 + @Job::Async::Memory::PENDING_JOBS; } )->on_ready(sub { delete $self->{'active'}; } ) |