view release on metacpan or  search on metacpan

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

package Gauge::AnyEvent_Curl_Multi;
use strict;
use utf8;
use warnings qw(all);

use Any::Moose;
with qw(Gauge::Role);

use AnyEvent;
use AnyEvent::Curl::Multi;
use HTTP::Request::Common qw(GET);
use WWW::Curl::Easy;

sub run {
    my ($self) = @_;

    my $multi = AnyEvent::Curl::Multi->new;
    $multi->max_concurrency($self->parallel);
    $multi->reg_cb(
        response => sub {
            my ($client, $request, $response, $stats) = @_;

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

package Gauge::Parallel_Downloader;
use strict;
use utf8;
use warnings qw(all);

use Any::Moose;
with qw(Gauge::Role);

use HTTP::Request::Common qw(GET);
use Parallel::Downloader;

sub run {
    my ($self) = @_;

    $AnyEvent::HTTP::USERAGENT = qq(Parallel::Downloader/$Parallel::Downloader::VERSION);
    my $parallel_downloader = Parallel::Downloader->new(
        requests        => [ map { GET($_) } @{$self->queue} ],
        workers         => $self->parallel,
        conns_per_host  => $self->parallel,

inc/Test/HTTP/AnyEvent/Server.pm  view on Meta::CPAN

use strict;
use utf8;
use warnings qw(all);

use AnyEvent;
use AnyEvent::Handle;
use AnyEvent::Log;
use AnyEvent::Socket;
use AnyEvent::Util;
use HTTP::Headers;
use HTTP::Request;
use HTTP::Response;
use Moo;
use MooX::Types::MooseLike::Base qw(:all);
use POSIX;

no if ($] >= 5.017010), warnings => q(experimental);

#$AnyEvent::Log::FILTER->level('debug');

our $VERSION = '0.007'; # VERSION