test.p6

use Test;

plan 5;

# MoarVM #165 (could not recv in a thread besides where the socket was
# accepted)
{
    my $ready = Promise.new;

    start {
        my $listen = IO::Socket::INET.new(:listen, :localport(10334));
        $ready.keep(True);
        loop {
            my $conn = $listen.accept;
            start {
                while my $buf = $conn.recv(:bin) {
                    $conn.write: $buf;
                }
                $conn.close;
            }
        }
    }

    await $ready;
    for ^5 {
        my $conn = IO::Socket::INET.new(:host<127.0.0.1>, :port(10334));
        $conn.print: "Can be handled on a thread";
        is $conn.recv, "Can be handled on a thread",
            "Server with recv on different thread responded ($_)";
        $conn.close;
    }
}