diff --git a/java_console/io/src/main/java/com/rusefi/binaryprotocol/BinaryProtocol.java b/java_console/io/src/main/java/com/rusefi/binaryprotocol/BinaryProtocol.java
index 59683f67fd..a44aad01e1 100644
--- a/java_console/io/src/main/java/com/rusefi/binaryprotocol/BinaryProtocol.java
+++ b/java_console/io/src/main/java/com/rusefi/binaryprotocol/BinaryProtocol.java
@@ -265,7 +265,6 @@ public class BinaryProtocol implements BinaryProtocolCommands {
             if (isClosed)
                 return;
             incomingData.dropPending();
-            stream.purge();
         }
     }
 
diff --git a/java_console/io/src/main/java/com/rusefi/io/IoStream.java b/java_console/io/src/main/java/com/rusefi/io/IoStream.java
index abf8688ed2..58f9c5f4be 100644
--- a/java_console/io/src/main/java/com/rusefi/io/IoStream.java
+++ b/java_console/io/src/main/java/com/rusefi/io/IoStream.java
@@ -48,9 +48,4 @@ public interface IoStream extends WriteStream {
     boolean isClosed();
 
     void close();
-
-    /**
-     * purges pending input and output
-     */
-    void purge();
 }
diff --git a/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStreamJSerialComm.java b/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStreamJSerialComm.java
index 2c708831b8..91352f2d1c 100644
--- a/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStreamJSerialComm.java
+++ b/java_console/io/src/main/java/com/rusefi/io/serial/SerialIoStreamJSerialComm.java
@@ -67,11 +67,6 @@ public class SerialIoStreamJSerialComm implements IoStream {
         logger.info(port + ": Closed port.");
     }
 
-    @Override
-    public void purge() {
-
-    }
-
     @Override
     public void write(byte[] bytes) {
         sp.writeBytes(bytes, bytes.length);
diff --git a/java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java b/java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java
index e56c37ca49..061ea428c7 100644
--- a/java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java
+++ b/java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java
@@ -49,11 +49,6 @@ public class TcpIoStream implements IoStream {
         output.flush();
     }
 
-    @Override
-    public void purge() {
-
-    }
-
     @Override
     public void setInputListener(final DataListener listener) {
         linkManager.TCP_READ_EXECUTOR.execute(new Runnable() {