Событийное и асинхронное программирование

my $loop=IO::Async::Loop->new;
$loop->add(IO::Async::Timer::Periodic->new(interval=>1,on_tick=>sub{poll_once()})->start);
$loop->run;

my $f=$client->GET($url);
$f->then(sub{ decode($_[0]) })->then(sub{ store($_[0]) })->retain;

$loop->add(IO::Async::Stream->new(handle=>$fh,on_read=>sub{ my($s,$buffref,$eof)=@_; consume_frames($buffref); return 0 }));

my $f=long_job();
$timer->on_expire(sub{ $f->cancel });

use Future::AsyncAwait;
async sub load { my $r=await fetch(); return decode($r) }

my $clock=$test_loop->time;
my $f=operation(timeout=>5);
$test_loop->advance_time(5);

on_tick=>sub{ sleep 10; fetch_sync() }

$future->on_done(sub { handle_result(@_) });
$future->on_fail(sub { warn "request failed: @_" });

my $n=sysread($fh,my $buf,1_000_000); process($buf);

$future=undef;

await blocking_db_call();

sleep 6; ok $f->is_failed;

my $timer = IO::Async::Timer::Periodic->new(
    interval => 1,
    on_tick => sub {
        start_async_fetch()->on_done(sub { handle_result(@_) });
    },
);

my $next = $future
    ->then(sub { transform(@_) })
    ->else(sub { recover($_[0]) });

while(my $frame=extract_complete_frame($buffer)){ process($frame) }

$f->on_cancel(sub{ close $socket; kill TERM=>$pid });

my $f=$adapter->call_async(@args); await $f;

inject_loop_and_clock(); simulate_read_chunks(); simulate_cancel();