diff --git a/java_console/io/src/main/java/com/rusefi/io/LinkManager.java b/java_console/io/src/main/java/com/rusefi/io/LinkManager.java
index 992e6fe6dc..c0351ca4c6 100644
--- a/java_console/io/src/main/java/com/rusefi/io/LinkManager.java
+++ b/java_console/io/src/main/java/com/rusefi/io/LinkManager.java
@@ -179,7 +179,7 @@ public class LinkManager {
         if (isLogViewerMode(port)) {
             setConnector(LinkConnector.VOID);
         } else if (TcpConnector.isTcpPort(port)) {
-            setConnector(new StreamConnector(this, port, logger, new Callable<IoStream>() {
+            Callable<IoStream> streamFactory = new Callable<IoStream>() {
                 @Override
                 public IoStream call() {
                     Socket socket;
@@ -193,10 +193,17 @@ public class LinkManager {
                         return null;
                     }
                 }
-            }));
+            };
+
+            
+
+            setConnector(new StreamConnector(this, port, logger, streamFactory));
             isSimulationMode = true;
         } else {
-            setConnector(new StreamConnector(this, port, logger, () -> SerialIoStreamJSerialComm.openPort(port, logger)));
+            Callable<IoStream> ioStreamCallable = () -> SerialIoStreamJSerialComm.openPort(port, logger);
+
+
+            setConnector(new StreamConnector(this, port, logger, ioStreamCallable));
         }
     }