tcp-chat.p6

use v6;

my @clients;
my $max_id = 0;
react {
    whenever IO::Socket::Async.listen('localhost', 3005) -> $sock {
        my $id = $max_id++;
        $sock.print("Hi! You are $id.\n");

        @clients>>.print("* $id connected\n");
        # aka: $_.print('stuff') for @clients
        @clients.push($sock);

        whenever $sock.chars-supply -> $bytes {
            @clients>>.print("{$id}: $bytes");
            LAST {
                @clients .= grep({ $_ !eqv $sock });
                @clients>>.print("* $id disconnected\n");
            }
        }
    }
}

tcp-chat.pl

my (@broadcast, %handlers);
while (1) {
    for my $sock ($select->can_read(1)) {
        if ($sock == $listen) {
            my $new = $listen->accept;
            $select->add($new);
            $handlers{$new->fileno} = {
                on_read => sub ($data) { push @broadcast, $new->fileno . ": $data" }
            };
            push @broadcast, sprintf("* %s connected\n", $new->fileno);
        } else {
            if ($sock->sysread(my $buffer, 4096, 0)) {
                $handlers{$sock->fileno}->{on_read}->($buffer);
            } else {
                push @broadcast, sprintf("* %s disconnected\n", $sock->fileno);
                $select->remove($sock) and $sock->close;
            }
        }
    }
    if (my @writable = $select->can_write(1)) {
        if (my $message = shift @broadcast) {
            $_->print($message) for @writable;
        }
    }
}