view release on metacpan or  search on metacpan

t/lib/Test/AQWrapper.pm  view on Meta::CPAN

package Test::AQWrapper;
use strict;
use warnings;
use base qw(Async::Queue);
use Test::More;
use Test::Builder;

sub new {
    my ($class, @args) = @_;
    my $self = $class->SUPER::new(@args);
    $self->{__finish_num} = 0;
    $self->{__push_num} = 0;
    return $self;
}

sub push {
    my ($self, @args) = @_;
    $self->{__push_num}++;
    return $self->SUPER::push(@args);
}

sub finish {
    my ($self) = @_;
    $self->{__finish_num}++;
}

sub clearCounter {
    my ($self) = @_;
    $self->{__push_num} = $self->{__finish_num} = 0;