use v6; react { whenever IO::Socket::Async.listen('0.0.0.0', 3333) -> $conn { my sub timeout() { $conn.print("TIMEOUT\n"); $conn.close; done; } my $tap = do whenever Promise.in(4) { timeout; }; whenever $conn.Supply.lines -> $line { $tap.close; $tap = do whenever Promise.in(4) { timeout; }; $conn.print("$line\n"); } } whenever signal(SIGINT) { done(); exit; } }