andreika-git
/
rusefi
mirror of https://github.com/andreika-git/rusefi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

proxy progress

This commit is contained in:
rusefi 2020-07-08 20:11:14 -04:00
parent 9cd91aafcb
commit 4f7302f268
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
java_console/io/src/main/java/com/rusefi/io/LinkManager.java
View File

@ -179,7 +179,7 @@ public class LinkManager {
if (isLogViewerMode(port)) { if (isLogViewerMode(port)) {
setConnector(LinkConnector.VOID); setConnector(LinkConnector.VOID);
} else if (TcpConnector.isTcpPort(port)) { } else if (TcpConnector.isTcpPort(port)) {
setConnector(new StreamConnector(this, port, logger, new Callable<IoStream>() { Callable<IoStream> streamFactory = new Callable<IoStream>() {
@Override @Override
public IoStream call() { public IoStream call() {
Socket socket; Socket socket;
@ -193,10 +193,17 @@ public class LinkManager {
return null; return null;
} }
} }
})); };
setConnector(new StreamConnector(this, port, logger, streamFactory));
isSimulationMode = true; isSimulationMode = true;
} else { } 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));
} }
} }