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.13";
use Mojo::UserAgent::Role::Queued::Queue;

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

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

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


1;
__END__