#!/opt/bin/perl
# This small example script shows how to do non-blocking
# reads from a file handle.
use AnyEvent::Handle;
my $cv = AnyEvent->condvar;
my $ae_fh =
    AnyEvent::Handle->new (
       fh => \*STDIN,
       on_error => sub { $cv->broadcast }
    );
$ae_fh->push_read (line => sub {
   my ($ae_fh, $line) = @_;
   print "Got line [$line]\n";
   $ae_fh->push_read (sub {
      my ($ae_fh) = @_;
      print "Got additional data:[\n".$ae_fh->rbuf."]\n";
      if ($ae_fh->rbuf =~ s/^.*\bend\b//s) {
         print "'end' detected, stopping program\n";
         $cv->broadcast;
         return 1;
      }
      return 0;
   });
});
$cv->wait;