AnyEvent-Fork-RPC/t/01_sync.t

$| = 1;
print "1..13\n";

use AnyEvent;
use AnyEvent::Fork::RPC;

print "ok 1\n";

my $done = AE::cv;

my $rpc = AnyEvent::Fork
   ->new
   ->eval (do { local $/; <DATA> })
   ->AnyEvent::Fork::RPC::run ("run",
      on_error   => sub { print "Bail out! $_[0]\n"; exit 1 },
      on_event   => sub { print "$_[0]\n" },
      on_destroy => $done,
   );

print "ok 2\n";

for (3..6) {
   $rpc->($_ * 2 - 1, sub { print $_[0] });
}

print "ok 3\n";

undef $rpc;

print "ok 4\n";

$done->recv;

print "ok 13\n";

__DATA__

sub run {
   my ($count) = @_;

   AnyEvent::Fork::RPC::event ("ok $count");

   "ok " . ($count + 1) . "\n"
}

Revision:	1.3
Committed:	Thu Apr 18 13:51:32 2013 UTC (13 years, 4 months ago) by root
Content type:	application/x-troff
Branch:	MAIN
CVS Tags:	rel-1_1, rel-0_1, rel-0_2
Changes since 1.2:	+0 -1 lines
Log Message:	* empty log message *
#	User	Rev	Content
1	root	1.1	$\| = 1;
2			print "1..13\n";
3
4			use AnyEvent;
5			use AnyEvent::Fork::RPC;
6
7			print "ok 1\n";
8
9			my $done = AE::cv;
10
11			my $rpc = AnyEvent::Fork
12			->new
13			->eval (do { local $/; <DATA> })
14			->AnyEvent::Fork::RPC::run ("run",
15			on_error => sub { print "Bail out! $_[0]\n"; exit 1 },
16			on_event => sub { print "$_[0]\n" },
17			on_destroy => $done,
18			);
19
20			print "ok 2\n";
21
22			for (3..6) {
23			$rpc->($_ * 2 - 1, sub { print $_[0] });
24			}
25
26			print "ok 3\n";
27
28			undef $rpc;
29
30			print "ok 4\n";
31
32			$done->recv;
33
34			print "ok 13\n";
35
36			__DATA__
37
38			sub run {
39			my ($count) = @_;
40
41			AnyEvent::Fork::RPC::event ("ok $count");
42
43			"ok " . ($count + 1) . "\n"
44			}
45