File Coverage

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

Criterion	Covered	Total	%
statement	6	6	100.0
branch			n/a
condition			n/a
subroutine	2	2	100.0
pod			n/a
total	8	8	100.0

package Mojo::UserAgent::Role::Queued;
use Mojo::Base '-role';

our $VERSION = "1.15";
use Mojo::UserAgent::Role::Queued::Queue;

has max_active => sub { shift->max_connections };

has job_queue => sub {
  Mojo::UserAgent::Role::Queued::Queue->new(max_active => shift->max_active);
};

around start => sub {
  my ($orig, $self, $tx, $cb) = @_;
  if ($cb) {
    unless ($self->job_queue->callback) {
        my $this = $self;
        weaken $this;
        $self->job_queue->callback(sub { $this->$orig(@_) });
    }
    unless ($self->job_queue->has_subscribers('queue_empty')) {
        my $this = $self;
        weaken $this;
        $self->job_queue->on(queue_empty => sub { $this->emit('queue_empty') });
    }
    $self->job_queue->enqueue($tx, $cb);
  }
  else {
    return $orig->($self, $tx);    # Blocking calls skip the queue
  }
};


1;
__END__