NAME
Mojo::Reactor - Low level event reactor base class
SYNOPSIS
$ENV {MOJO_REACTOR} ||= 'Mojo::Reactor::MyEventLoop' ;
sub io {...}
sub is_running {...}
sub one_tick {...}
sub recurring {...}
sub remove {...}
sub start {...}
sub stop {...}
sub timer {...}
sub watch {...}
1;
|
DESCRIPTION
Mojo::Reactor is an abstract base class for low level event reactors.
EVENTS
Mojo::Reactor can emit the following events.
error
$reactor ->on( error => sub {
my ( $reactor , $err ) = @_ ;
...
});
|
Emitted safely for exceptions caught in callbacks.
$reactor ->on( error => sub {
my ( $reactor , $err ) = @_ ;
say "Something very bad happened: $err" ;
});
|
METHODS
Mojo::Reactor inherits all methods from Mojo::EventEmitter and implements the following new ones.
detect
my $class = Mojo::Reactor->detect;
|
Detect and load the best reactor implementation available, will try the value of the MOJO_REACTOR
environment variable, Mojo::Reactor::EV or Mojo::Reactor::Poll.
my $reactor = Mojo::Reactor->detect->new;
|
io
$reactor = $reactor ->io( $handle => sub {...});
|
Watch handle for I/O events, invoking the callback whenever handle becomes readable or writable. Meant to be overloaded in a subclass.
$reactor ->io( $handle => sub {
my ( $reactor , $writable ) = @_ ;
say $writable ? 'Handle is writable' : 'Handle is readable' ;
});
|
is_readable
my $success = $reactor ->is_readable( $handle );
|
Quick non-blocking check if a handle is readable, useful for identifying tainted sockets.
is_running
my $success = $reactor ->is_running;
|
Check if reactor is running. Meant to be overloaded in a subclass.
one_tick
Run reactor until an event occurs or no events are being watched anymore. Note that this method can recurse back into the reactor, so you need to be careful. Meant to be overloaded in a subclass.
my $id = $reactor ->timer(0. 5 => sub {});
$reactor ->one_tick;
$reactor ->remove( $id );
|
recurring
my $id = $reactor ->recurring(0. 25 => sub {...});
|
Create a new recurring timer, invoking the callback repeatedly after a given amount of time in seconds. Meant to be overloaded in a subclass.
$reactor ->recurring( 0 => sub { say 'Reactor tick.' });
|
remove
my $success = $reactor ->remove( $handle );
my $success = $reactor ->remove( $id );
|
Remove handle or timer. Meant to be overloaded in a subclass.
start
Start watching for I/O and timer events, this will block until stop
is called or no events are being watched anymore. Meant to be overloaded in a subclass.
stop
Stop watching for I/O and timer events. Meant to be overloaded in a subclass.
timer
my $id = $reactor ->timer(0. 5 => sub {...});
|
Create a new timer, invoking the callback after a given amount of time in seconds. Meant to be overloaded in a subclass.
$reactor ->timer( 0 => sub { say 'Next tick.' });
|
watch
$reactor = $reactor ->watch( $handle , $readable , $writable );
|
Change I/O events to watch handle for with true
and false
values, meant to be overloaded in a subclass. Note that this method requires an active I/O watcher.
$reactor ->watch( $handle , 1, 0);
$reactor ->watch( $handle , 0, 1);
$reactor ->watch( $handle , 1, 1);
$reactor ->watch( $handle , 0, 0);
|
SEE ALSO
Mojolicious, Mojolicious::Guides, http://mojolicio.us.