elementary_pipes.pl

use strict;
use warnings;
use Data::Dumper;
use AnyEvent::Handle;
use AnyEvent;

my($pipe_w, $pipe_r);
pipe $pipe_r, $pipe_w;

my $cv = AnyEvent->condvar;

## Asynchronous buffers
my $wh = new AnyEvent::Handle(fh => $pipe_w);
my $rh = new AnyEvent::Handle(fh => $pipe_r);
$wh->push_write(json => ["112"]);
$rh->push_read(json => sub {
    my($handle, $payload) = @_;
    print Dumper $payload;
    $cv->send;
});

$cv->recv;

undef $wh;
undef $rh;
close $pipe_w;
close $pipe_r;