From 4f7302f26809e30a78e67d07839a6236b0580b5b Mon Sep 17 00:00:00 2001
From: rusefi <rusefillc@gmail.com>
Date: Wed, 8 Jul 2020 20:11:14 -0400
Subject: [PATCH] proxy progress

---
 .../io/src/main/java/com/rusefi/io/LinkManager.java | 13 ++++++++++---
 1 file changed, 10 insertions(+), 3 deletions(-)

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));
         }
     }