proxy progress

java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java

@@ -33,8 +33,7 @@ public class TcpIoStream implements IoStream {
             throw new NullPointerException("output");
         this.output = output;
         this.input = input;
-        IncomingDataBuffer dataBuffer = IncomingDataBuffer.createDataBuffer(this, logger);
-        this.dataBuffer = dataBuffer;
+        this.dataBuffer = IncomingDataBuffer.createDataBuffer(this, logger);
     }
 
     @Override

java_console/ui/src/main/java/com/rusefi/autodetect/SerialAutoChecker.java

@@ -39,7 +39,7 @@ public class SerialAutoChecker implements Runnable {
     public void run() {
         IoStream stream = SerialIoStreamJSerialComm.openPort(serialPort, logger);
         Logger logger = FileLog.LOGGER;
-        IncomingDataBuffer incomingData = IncomingDataBuffer.createDataBuffer(stream, logger);
+        IncomingDataBuffer incomingData = stream.getDataBuffer();
         try {
             stream.sendPacket(new byte[]{BinaryProtocolCommands.COMMAND_HELLO}, logger);
             byte[] response = incomingData.getPacket(logger, "", false);

java_console/ui/src/main/java/com/rusefi/tools/ConsoleTools.java

@@ -308,7 +308,7 @@ public class ConsoleTools {
         }
         IoStream stream = SerialIoStreamJSerialComm.openPort(autoDetectedPort, FileLog.LOGGER);
         Logger logger = FileLog.LOGGER;
-        IncomingDataBuffer incomingData = IncomingDataBuffer.createDataBuffer(stream, logger);
+        IncomingDataBuffer incomingData = stream.getDataBuffer();
         byte[] commandBytes = BinaryProtocol.getTextCommandBytes("hello");
         stream.sendPacket(commandBytes, logger);
         // skipping response