NAME

CPS::Governor::IOAsync - use IO::Async with CPS

SYNOPSIS

            

              
              
use CPS qw( gkforeach );
use CPS::Governor::IOAsync;
use IO::Async::Loop;
my $loop = IO::Async::Loop->new;
my $gov = CPS::Governor::IOAsync->new( loop => $loop );
gkforeach( $gov, [ 1 .. 10 ],
   sub {
      my ( $item, $knext ) = @_;
      $loop->do_something( on_done => $knext );
   },
   sub { $loop->loop_stop },
);
$loop->loop_forever;
            
          

DESCRIPTION

This CPS::Governor allows functions using it to defer their re-execution by using the IO::Async::Loop later method, meaning it will interleave with other IO operations performed by IO::Async.

CONSTRUCTOR

$gov = CPS::Governor::IOAsync->new( %args )

Returns a new instance of a CPS::Governor::IOAsync object. Requires the following argument:

loop => IO::Async::Loop

Reference to the IO::Async::Loop object.

Additionally may take any other arguments defined by the CPS::Governor::Deferred class.

AUTHOR

Paul Evans <leonerd@leonerd.org.uk>