commit
dead33a90a
|
@ -72,7 +72,8 @@ class TunnelClientTests {
|
||||||
TunnelClient client = new TunnelClient(0, this.tunnelConnection);
|
TunnelClient client = new TunnelClient(0, this.tunnelConnection);
|
||||||
int port = client.start();
|
int port = client.start();
|
||||||
SocketChannel channel = SocketChannel.open(new InetSocketAddress(port));
|
SocketChannel channel = SocketChannel.open(new InetSocketAddress(port));
|
||||||
Thread.sleep(200);
|
Awaitility.await().atMost(Duration.ofSeconds(30)).until(this.tunnelConnection::getOpenedTimes,
|
||||||
|
(open) -> open == 1);
|
||||||
channel.close();
|
channel.close();
|
||||||
client.getServerThread().stopAcceptingConnections();
|
client.getServerThread().stopAcceptingConnections();
|
||||||
client.getServerThread().join(2000);
|
client.getServerThread().join(2000);
|
||||||
|
|
Loading…
Reference in New Issue