diff --git a/java_console/io/src/com/rusefi/binaryprotocol/BinaryProtocol.java b/java_console/io/src/com/rusefi/binaryprotocol/BinaryProtocol.java
index c81e8ea8cc..89af4858d0 100644
--- a/java_console/io/src/com/rusefi/binaryprotocol/BinaryProtocol.java
+++ b/java_console/io/src/com/rusefi/binaryprotocol/BinaryProtocol.java
@@ -66,13 +66,7 @@ public class BinaryProtocol implements BinaryProtocolCommands {
         this.stream = stream;
 
         incomingData = new IncomingDataBuffer(logger);
-        DataListener streamDataListener = new DataListener() {
-            @Override
-            public void onDataArrived(byte[] freshData) {
-                incomingData.addData(freshData);
-            }
-        };
-        stream.setInputListener(streamDataListener);
+        stream.setInputListener(incomingData::addData);
     }
 
     private static void sleep() {