1313import java .time .Duration ;
1414import java .util .concurrent .atomic .AtomicBoolean ;
1515import java .util .function .Function ;
16+
17+ import org .junit .jupiter .api .AfterEach ;
18+ import org .junit .jupiter .api .BeforeEach ;
1619import org .junit .jupiter .api .Test ;
1720import org .slf4j .Logger ;
1821import org .slf4j .LoggerFactory ;
@@ -29,9 +32,21 @@ public class KeepaliveTest {
2932 private static final Logger LOG = LoggerFactory .getLogger (KeepaliveTest .class );
3033 private static final int PORT = 23200 ;
3134
35+ private CloseableChannel server ;
36+
37+ @ BeforeEach
38+ void setUp () {
39+ server = createServer ().block ();
40+ }
41+
42+ @ AfterEach
43+ void tearDown () {
44+ server .dispose ();
45+ server .onClose ().block ();
46+ }
47+
3248 @ Test
3349 void keepAliveTest () {
34- createServer ().block ();
3550 RSocketClient rsocketClient = createClient ();
3651
3752 int expectedCount = 4 ;
@@ -64,7 +79,6 @@ void keepAliveTest() {
6479
6580 @ Test
6681 void keepAliveTestLazy () {
67- createServer ().block ();
6882 Mono <RSocket > rsocketMono = createClientLazy ();
6983
7084 int expectedCount = 4 ;
@@ -161,21 +175,6 @@ private static Mono<RSocket> createClientLazy() {
161175 .reconnect (reconnectSpec .apply ("connector-close" ))
162176 .keepAlive (Duration .ofMillis (100L ), Duration .ofMillis (900L ))
163177 .connect (TcpClientTransport .create (TcpClient .create ().host ("localhost" ).port (PORT )));
164-
165- // RSocketClient client = RSocketClient.from(rsocketMono);
166-
167- // client
168- // .source()
169- // .doOnNext(r -> LOG.info("Got RSocket"))
170- // .flatMap(RSocket::onClose)
171- // .doOnError(err -> LOG.error("Error during onClose.", err))
172- // .retryWhen(reconnectSpec.apply("client-close"))
173- // .doFirst(() -> LOG.info("Connected on client side."))
174- // .doOnTerminate(() -> LOG.info("Connection closed on client side."))
175- // .repeat()
176- // .subscribe();
177-
178- // return client;
179178 }
180179
181180 public static class MyServerRsocket implements RSocket {
0 commit comments