fix format and failing test

Signed-off-by: Oleh Dokuka <[email protected]>

Author: OlegDokuka

rsocket-core/src/main/java/io/rsocket/core/RSocketRequester.java

@@ -309,14 +309,10 @@ private void handleMissingResponseProcessor(int streamId, FrameType type, ByteBu
 
   private void tryTerminateOnKeepAlive(KeepAliveSupport.KeepAlive keepAlive) {
     tryTerminate(
-        () -> {
-          ConnectionErrorException exception =
-              new ConnectionErrorException(
-                  String.format("No keep-alive acks for %d ms", keepAlive.getTimeout().toMillis()));
-
-          getDuplexConnection().dispose();
-          return exception;
-        });
+        () ->
+            new ConnectionErrorException(
+                String.format("No keep-alive acks for %d ms", keepAlive.getTimeout().toMillis())));
+    getDuplexConnection().dispose();
   }
 
   private void tryShutdown(Throwable e) {

rsocket-transport-netty/src/test/java/io/rsocket/integration/KeepaliveTest.java

@@ -13,7 +13,6 @@
 import java.time.Duration;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.function.Function;
-
 import org.junit.jupiter.api.AfterEach;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;