File Coverage

blib/lib/IO/Concurrent.pm

Criterion	Covered	Total	%
statement	11	22	50.0
branch			n/a
condition	0	2	0.0
subroutine	4	7	57.1
pod	0	2	0.0
total	15	33	45.4

package IO::Concurrent;
use 5.008001;
use strict;
use warnings;

our $VERSION = "0.01";

use IO::Concurrent::Runner;

sub new {
    my ($class, %args) = @_;
    $args{engine} ||= 'Select';
    return bless \%args => $class;
}

sub run {
    my ($self, $scenario) = @_;
    my @contexts = map { $scenario->create_context($_) } @{ $self->{handlers} };
    my $runner = $self->_create_runner(\@contexts, {
        on_error => $scenario->on_error,
    });
    $runner->run();
}

sub _create_runner {
    my $self = shift;
    return IO::Concurrent::Runner->engine($self->{engine})->new(@_);
}

1;
__END__