=head1 NAME Coro::EV - do events the coro-way =head1 SYNOPSIS use Coro; use Coro::EV; EV::loop; =head1 DESCRIPTION This module does two things: First, it offers some utility functions that might be useful for coroutines, and secondly, it integrates Coro into the EV main loop: Before the process blocks (in EV::loop) to wait for events, this module will schedule and run all ready (= runnable) coroutines of the same or higher priority. After that, it will cede once to a coroutine of lower priority, then continue in the event loop. That means that coroutines with the same or higher pripority as the coroutine running the main loop will inhibit event processing, while coroutines of lower priority will get the CPU, but cannot completeley inhibit event processing. =head2 RUNNING WITH OR WITHOUT A MAINLOOP In general, you should always run EV::loop, either in your main program, or in a separate coroutine. If you don't do that and all coroutines start waiting for some events, this module will run the event loop once, but this is very inefficient. =head1 FUNCTIONS =over 4 =cut package Coro::EV; no warnings; use strict; use Carp; no warnings; use Coro; use EV (); use XSLoader; BEGIN { our $VERSION = 4.749; local $^W = 0; # avoid redefine warning for Coro::ready; XSLoader::load __PACKAGE__, $VERSION; } our $IDLE = new Coro sub { while () { &_loop_oneshot; &Coro::schedule; } }; $IDLE->{desc} = "[EV idle process]"; $Coro::idle = sub { $IDLE->ready }; =item $revents = Coro::EV::timed_io_once $fileno_or_fh, $events, $timeout Blocks the coroutine until either the given event set has occured on the fd, or the timeout has been reached (if timeout is zero, there is no timeout). Returns the received flags. =cut sub timed_io_once($$;$) { &_timed_io_once; do { &Coro::schedule } while !$#_; pop } =item Coro::EV::timer_once $after Blocks the coroutine for at least C<$after> seconds. =cut sub timer_once($) { &_timer_once; do { &Coro::schedule } while !$#_; pop } sub readable_ev { _readable_ev $_[0], my $done; do { &Coro::schedule } while !defined $done; $done } sub writable_ev { _writable_ev $_[0], my $done; do { &Coro::schedule } while !defined $done; $done } 1; =back =head1 AUTHOR Marc Lehmann http://home.schmorp.de/ =cut