[ViewVC] Contents of: cvs/AnyEvent/eg/handle

#!/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_eof => 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;
Revision:	1.2
Committed:	Thu May 15 08:37:55 2008 UTC (16 years, 1 month ago) by elmex
Branch:	MAIN
CVS Tags:	rel-4_0, rel-3_5
Changes since 1.1:	+0 -1 lines
Log Message:	implemented non-blocking connects in a different manner than ::Socket.
#	Content
1	#!/opt/bin/perl
2	# This small example script shows how to do non-blocking
3	# reads from a file handle.
4
5	use AnyEvent::Handle;
6	my $cv = AnyEvent->condvar;
7
8	my $ae_fh =
9	AnyEvent::Handle->new (
10	fh => \*STDIN,
11	on_eof => sub { $cv->broadcast }
12	);
13
14	$ae_fh->push_read_line (sub {
15	my ($ae_fh, $line) = @_;
16	print "Got line [$line]\n";
17
18	$ae_fh->push_read (sub {
19	my ($ae_fh) = @_;
20	print "Got additional data:[\n".$ae_fh->rbuf."]\n";
21
22	if ($ae_fh->rbuf =~ s/^.*\bend\b//s) {
23	print "'end' detected, stopping program\n";
24	$cv->broadcast;
25	return 1;
26	}
27
28	return 0;
29	});
30	});
31
32	$cv->wait;