Skip to content

Commit

Permalink
OutboundConnectionsMultiplexerTest: Rename address to serverAddress
Browse files Browse the repository at this point in the history
  • Loading branch information
alvasw committed May 23, 2023
1 parent c082f4c commit ce93652
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -56,8 +56,8 @@ void startServerAndConnectAfterItsReady() throws IOException, InterruptedExcepti
ArrayList<Transport.Type> supportedTransportTypes = new ArrayList<>();
supportedTransportTypes.add(Transport.Type.CLEAR);

Address address = Address.localHost(NetworkUtils.findFreeSystemPort());
Capability serverCapability = new Capability(address, supportedTransportTypes);
Address serverAddress = Address.localHost(NetworkUtils.findFreeSystemPort());
Capability serverCapability = new Capability(serverAddress, supportedTransportTypes);
ServerChannel serverChannel = new ServerChannel(
serverCapability,
mock(BanList.class),
Expand Down Expand Up @@ -94,7 +94,7 @@ void startServerAndConnectAfterItsReady() throws IOException, InterruptedExcepti
var connectionMultiplexer = new OutboundConnectionMultiplexer(outboundConnectionManager);
connectionMultiplexer.start();

CompletableFuture<OutboundConnectionChannel> connection = connectionMultiplexer.getConnection(address);
CompletableFuture<OutboundConnectionChannel> connection = connectionMultiplexer.getConnection(serverAddress);
return connection.get(1, TimeUnit.MINUTES);


Expand Down

0 comments on commit ce93652

Please sign in to comment.