File Coverage

blib/lib/EntityModel/EventLoop/IO/Async.pm

Criterion	Covered	Total	%
statement	3	3	100.0
branch			n/a
condition			n/a
subroutine	1	1	100.0
pod			n/a
total	4	4	100.0

package EntityModel::EventLoop::IO::Async;
# ABSTRACT: Wrapper around an IO::Async::Loop instance
use EntityModel::Class {
	_isa => [qw(EntityModel::EventLoop)],
	loop => 'IO::Async::Loop',
};

our $VERSION = '0.001';

=head1 NAME

EntityModel::EventLoop::IO::Async - handler for L object.

=head1 VERSION

version 0.001

=head1 DESCRIPTION

Support for an L event loop.

=head1 METHODS

=cut

=head2 loop

Direct accessor for the L object, can be used to provide a specific loop:

 $el->loop(IO::Async::Loop::Epoll->new);

=cut

=head2 event_loop

Returns the event loop, instantiating a new one if necessary. Should be used in preference
to L for making sure that a valid event loop is available, since this will raise an
exception if no event loop could be instantiated.

=cut

sub event_loop {
	my $self = shift;
	$self->loop(IO::Async::Loop->new) unless $self->loop;
	return $self->loop || die "No event loop available";
}

=head2 defer

Defers execution of the given codeblock using Llater( $code )>.

=cut

sub defer {
	my $self = shift;
	my $code = shift;
	$self->event_loop->later($code);
	$self;
}

=head2 sleep

Runs the given code block after an interval.

Instance method which expects an interval (in seconds) and a single coderef.

=cut

sub sleep {
	my $self = shift;
	my ($interval, $code) = @_;
	$self->event_loop->enqueue_timer(
		delay => $interval,
		code => $code
	);
	return $self;
}

1;

__END__