AnyEvent-Net-Curl-Queued

 view release on metacpan or  search on metacpan

eg/Gauge/Role.pm  view on Meta::CPAN

has fork_manager=> (
    is      => 'ro',
    isa     => 'Parallel::ForkManager',
    lazy    => 1,
    default => sub {
        Parallel::ForkManager->new(shift->parallel);
    },
);
has parallel    => (is => 'ro', isa => 'Int', default => 4);
has queue       => (is => 'ro', isa => 'ArrayRef[Str]', required => 1);
has split       => (
    is      => 'rw',
    isa     => 'ArrayRef[ArrayRef[Str]]',
    lazy    => 1,
    default => sub {
        my ($self) = @_;
        my @split;
        for my $i (0 .. $#{$self->queue}) {
            my $j = $i % $self->parallel;
            push @{$split[$j]}, $self->queue->[$i];

lib/AnyEvent/Net/Curl/Queued.pm  view on Meta::CPAN

use Net::Curl::Share;

use AnyEvent::Net::Curl::Queued::Multi;

our $VERSION = '0.049'; # VERSION


has allow_dups  => (is => 'ro', isa => Bool, default => sub { 0 });


has common_opts => (is => 'ro', isa => HashRef, default => sub { {} });


has http_response => (is => 'ro', isa => Bool, default => sub { 0 });


has completed  => (
    is          => 'ro',
    isa         => Int,
    default     => sub { 0 },
    writer      => 'set_completed',

lib/AnyEvent/Net/Curl/Queued/Multi.pm  view on Meta::CPAN

set_prototype \&Net::Curl::Multi::new           => undef;
set_prototype \&Net::Curl::Multi::socket_action => undef;
set_prototype \&Net::Curl::Multi::add_handle    => undef;

extends 'Net::Curl::Multi';


has active      => (is => 'ro', isa => Int, default => sub { -1 }, writer => 'set_active');


has pool        => (is => 'ro', isa => HashRef[Ref], default => sub { {} });


has timer       => (is => 'ro', isa => AnyOf[ArrayRef, Object], writer => 'set_timer', clearer => 'clear_timer', predicate => 'has_timer', weak_ref => 0);


has max         => (is => 'ro', isa => Num, default => sub { 4 });


has timeout     => (is => 'ro', isa => Num, default => sub { 60.0 });

our $VERSION = '0.049'; # VERSION

 view all matches for this distribution
 view release on metacpan -  search on metacpan