diff --git a/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java b/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java index bb5f82dfa4..71bedd9320 100644 --- a/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java +++ b/java_console/io/src/main/java/com/rusefi/binaryprotocol/IncomingDataBuffer.java @@ -140,4 +140,20 @@ public class IncomingDataBuffer { cbb.get(packet); } } + + public byte readByte() throws EOFException { + return (byte) getByte(); + } + + public int readInt() throws EOFException { + return getInt(); + } + + public int read(byte[] packet) throws InterruptedException { + boolean timeout = waitForBytes("read", System.currentTimeMillis(), packet.length); + if (timeout) + throw new IllegalStateException("Timeout while waiting " + packet.length); + getData(packet); + return packet.length; + } }