chat-server.p6

use v6;

my $message-bus = Supply.new();
sub handle-socket ($id, $sock) {
    $message-bus.emit("* $id has connected\n");
    react {
        whenever $message-bus -> $message {
            $sock.print($message);
        }
        whenever $sock.chars-supply -> $bytes {
            $message-bus.emit("$id: $bytes");
            LAST {
                $message-bus.emit("* $id has disconnected\n");
                return;
            }
        }
    }
}

my $max-id = 0;
say "listening on port 3005 ... ";
react {
    whenever IO::Socket::Async.listen('localhost', 3005) -> $sock {
        my $id = $max-id++;
        start {
            handle-socket($id, $sock);
        }
    }
}