view release on metacpan or  search on metacpan

t/70-timeout.t  view on Meta::CPAN

#!perl
use lib qw(inc);
use strict;
use utf8;
use warnings qw(all);

use Test::More;

use AnyEvent::Net::Curl::Queued;
use AnyEvent::Net::Curl::Queued::Easy;
use Test::HTTP::AnyEvent::Server;

use lib qw(t);
use_ok(q(Timeouter));

my $server = Test::HTTP::AnyEvent::Server->new;
my $q = AnyEvent::Net::Curl::Queued->new(
    timeout         => 5,   # allow watchdog to manifest itself
);

$q->append(sub {
    Timeouter->new(
        initial_url => $server->uri . 'delay/20',   # 3x timeout
        retry       => 3,
    )
});

$q->append(sub {
    AnyEvent::Net::Curl::Queued::Easy->new(
        initial_url => $server->uri . 'delay/1',
        on_finish   => sub {
            my ($self, $result) = @_;
            is(0 + $result, 0, 'got CURLE_OK');
            chomp(my $body = ${$self->data});
            like(${$self->data}, qr{^issued\s+}ix, qq(got data: "$body"));
        },
        retry       => 3,
    )
});

$q->wait;

is(
    $q->completed,
    3 + 1,
    qq(retries detected [@{[ scalar localtime ]}]),
);

done_testing 7;