summary |
shortlog |
log |
commit | commitdiff |
review |
tree
raw |
patch |
inline | side by side (from parent 1:
f6ec1f4)
Client's toString() changes when the connection completes. Move the
check to after we have waited for callbacks.
JIRA: NETCONF-590
Change-Id: I1ad7e375ca60d350affd1b226fa11ffc87106fe6
Signed-off-by: Robert Varga <robert.varga@pantheon.tech>
final var client = TCPClient.connect(clientListener, NettyTransportSupport.newBootstrap().group(group),
clientGrouping).get(2, TimeUnit.SECONDS);
try {
final var client = TCPClient.connect(clientListener, NettyTransportSupport.newBootstrap().group(group),
clientGrouping).get(2, TimeUnit.SECONDS);
try {
- assertThat(client.toString(), allOf(
- startsWith("TCPClient{listener=clientListener, state=TCPTransportChannel{channel=[id: 0x"),
- endsWith(":" + serverPort.getValue() + "]}}")));
-
verify(serverListener, timeout(500)).onTransportChannelEstablished(any());
final var serverTransports = serverCaptor.getAllValues();
assertEquals(1, serverTransports.size());
verify(serverListener, timeout(500)).onTransportChannelEstablished(any());
final var serverTransports = serverCaptor.getAllValues();
assertEquals(1, serverTransports.size());
assertThat(clientTransports.get(0).toString(), allOf(
startsWith("TCPTransportChannel{channel=[id: "),
endsWith(":" + serverPort.getValue() + "]}")));
assertThat(clientTransports.get(0).toString(), allOf(
startsWith("TCPTransportChannel{channel=[id: "),
endsWith(":" + serverPort.getValue() + "]}")));
+
+ assertThat(client.toString(), allOf(
+ startsWith("TCPClient{listener=clientListener, state=TCPTransportChannel{channel=[id: 0x"),
+ endsWith(":" + serverPort.getValue() + "]}}")));
} finally {
client.shutdown().get(2, TimeUnit.SECONDS);
}
} finally {
client.shutdown().get(2, TimeUnit.SECONDS);
}