File Coverage

blib/lib/ONE/Collect.pm

Criterion	Covered	Total	%
statement	33	33	100.0
branch	3	4	75.0
condition			n/a
subroutine	8	8	100.0
pod	2	2	100.0
total	46	47	97.8

# ABSTRACT: Collect
package ONE::Collect;
{
  $ONE::Collect::VERSION = 'v0.2.0';
}
use strict;
use warnings;
use AnyEvent;
use Any::Moose;

has '_cv' => (isa=>'AnyEvent::CondVar', is=>'rw');


sub listener {
    my $self = shift;
    my( $todo ) = @_;

    # Create a new CV if we don't have one yet
    my $cv = $self->_cv;
    unless ( $cv ) {
        $self->_cv( $cv = AE::cv );
    }

    # Begin processing
    $cv->begin;

    # Here we wrap the event listener and, after the first call, remove ourselves
    my $wrapped;
    $wrapped = sub {
        my $self = shift;
        $self->remove_listener( $self->current_event, $wrapped );
        $self->on( $self->current_event, $todo );
        $todo->(@_);
        $cv->end;
        undef $wrapped;
    };
    return $wrapped;
}



sub complete {
    my $self = shift;
    return unless defined $self->_cv;
    $self->_cv->wait;
}


__PACKAGE__->meta->make_immutable();
no Any::Moose;


1;


__END__