Untitled

use v6;

class X::Timeout is Exception {
    method message { "Timed out" }
}

sub timeout(Supply $in, $timeout) {
    supply {
        my $last = now;
        whenever $in {
            $last = now;
            emit $_
        }
        whenever Supply.interval(0.1) {
            if now - $last > $timeout {
                X::Timeout.new.throw;
            }
        }
    }
}

react {
    whenever IO::Socket::Async.listen('0.0.0.0', 3333) -> $conn {
        whenever timeout($conn.Supply.lines, 4) -> $line {
            $conn.print("$line\n");
            QUIT {
                when X::Timeout {
                    $conn.print("TIMEOUT\n");
                    $conn.close;
                }
            }
        }
    }
    whenever signal(SIGINT) { done(); exit; }
}