[ViewVC] Annotation of: cvs/AnyEvent-MP/eg/chat_server

#!/opt/bin/perl

use AnyEvent;
use AnyEvent::MP;

become_public "127.0.0.1:1299";

my $chatter_port = port;

reg $chatter_port, "chatter";

my %client_ports;

rcv $chatter_port,
   join => sub {
      my ($tag, $client_port) = @_;

      print "got new client port: $client_port\n";
      $client_ports{$client_port} = 1;

      0
   },
   message => sub {
      my ($tag, $msg) = @_;

      print "message> $msg\n";

      snd $_, message => $msg
         for keys %client_ports;

      0
   };

AnyEvent->condvar->recv;
Revision:	1.2
Committed:	Tue Aug 4 21:06:48 2009 UTC (14 years, 9 months ago) by root
Branch:	MAIN
CVS Tags:	rel-0_1, rel-0_4
Changes since 1.1:	+20 -17 lines
Log Message:	* empty log message *
#	User	Rev	Content
1	root	1.2	#!/opt/bin/perl
2
3	elmex	1.1	use AnyEvent;
4			use AnyEvent::MP;
5
6	root	1.2	become_public "127.0.0.1:1299";
7
8			my $chatter_port = port;
9	elmex	1.1
10	root	1.2	reg $chatter_port, "chatter";
11	elmex	1.1
12			my %client_ports;
13
14	root	1.2	rcv $chatter_port,
15			join => sub {
16			my ($tag, $client_port) = @_;
17	elmex	1.1
18	root	1.2	print "got new client port: $client_port\n";
19			$client_ports{$client_port} = 1;
20	elmex	1.1
21	root	1.2	0
22			},
23			message => sub {
24			my ($tag, $msg) = @_;
25	elmex	1.1
26	root	1.2	print "message> $msg\n";
27	elmex	1.1
28	root	1.2	snd $_, message => $msg
29			for keys %client_ports;
30	elmex	1.1
31	root	1.2	0
32			};
33	elmex	1.1
34			AnyEvent->condvar->recv;