perl6 async/thread socket load test client/echo server

client.p6

sub MAIN( Str :$host = '127.0.0.1', Int :$port!, Int :$connections!, Bool :$os_threads? ) {
	my %threads;

	(1..$connections).map(-> $count {
		my $makesock = 	{
			my $client = IO::Socket::INET.new( host => $host, port => $port ); 
			$client.send($count);
			say "count: $count | returned: " ~ $client.recv;
		};

		%threads{$count} = $os_threads??Thread.start($makesock)!!(async $makesock);	
	});

	$os_threads??(.join for %threads.values)!!(await %threads.values);
	say 'All ' 
	~	($os_threads??'threads'!!'asyncs')
	~	' finished';
}

echoserver.p6

class echo {
  has %.opts is readonly = (
    port            => 9001,
    host            => '127.0.0.1',
    middlewares     => (),
    max_concurrency => 40,
  );
  has Bool             $.open  is readonly = False;

  has IO::Socket::INET $!server;
  method start {
    $!server = IO::Socket::INET.new(
      :localhost(%.opts<host>),
      :localport(%.opts<port>),
      :listen,
    );
    $!open   = True;
    my $cnt  = 0;
    async {
        loop {
  		my $conn = $!server.accept;
			say 'Got connection!';

	        try {
	          my $req = $conn.recv;
	          say "got $req";
	          $conn.send($req);
	          say "\tsending $req";

	          CATCH { default {
	            try { $conn.close; CATCH { default { } } };
	          } };
	        };
        }
    };
  };
};



my $s = echo.new;

$s.start;

say 'listening..' if $s.open;
while $s.open {  };