#!/opt/perl/bin/perl
use AnyEvent;
use AnyEvent::MP;

become_public "localhost:1299";

my $chatter_port = create_port;
$chatter_port->register ("chatter");

my %client_ports;

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

   print "got new client port: $client_port\n";

   $client_ports{$client_port} = 1;
   0
});

$chatter_port->rcv (message => sub {
   my ($chatter_port, $type, $msg) = @_;

   print "message> $msg\n";

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

AnyEvent->condvar->recv;