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 920f43f001..6238d049a0 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 @@ -14,6 +14,7 @@ import com.rusefi.io.tcp.TcpIoStream; import org.jetbrains.annotations.NotNull; import java.io.Closeable; +import java.io.IOException; import java.util.Arrays; import java.util.Objects; import java.util.concurrent.*; @@ -64,6 +65,13 @@ public class LinkManager implements Closeable { commandQueue = new CommandQueue(this); } + @NotNull + public static IoStream open(String port) throws IOException { + if (TcpConnector.isTcpPort(port)) + return TcpIoStream.open(port); + return SerialIoStreamJSerialComm.openPort(port); + } + @NotNull public CountDownLatch connect(String port) { final CountDownLatch connected = new CountDownLatch(1); diff --git a/java_console/io/src/main/java/com/rusefi/io/tcp/TcpConnector.java b/java_console/io/src/main/java/com/rusefi/io/tcp/TcpConnector.java index e1a03dd977..48f244aa28 100644 --- a/java_console/io/src/main/java/com/rusefi/io/tcp/TcpConnector.java +++ b/java_console/io/src/main/java/com/rusefi/io/tcp/TcpConnector.java @@ -42,7 +42,7 @@ public class TcpConnector { return confirmation.substring(0, length); } */ - public static class InvalidTcpPort extends Exception { + public static class InvalidTcpPort extends IOException { } public static int getTcpPort(String port) throws InvalidTcpPort {