From 6d25864d98d138f274c738c0ae009b0d8cc112eb Mon Sep 17 00:00:00 2001
From: rusefi <rusefillc@gmail.com>
Date: Wed, 8 Jul 2020 16:37:34 -0400
Subject: [PATCH] Revert "proxy progress"

This reverts commit 968015f5
---
 .../java/com/rusefi/binaryprotocol/BinaryProtocol.java    | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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 4944228aa9..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
@@ -118,7 +118,7 @@ public class BinaryProtocol implements BinaryProtocolCommands {
             }
         };
 
-        incomingData = stream.getDataBuffer();
+        incomingData = createDataBuffer(stream, logger);
         Runtime.getRuntime().addShutdownHook(hook);
         rpmListener = value -> {
             if (value <= COMPOSITE_OFF_RPM) {
@@ -131,6 +131,12 @@ public class BinaryProtocol implements BinaryProtocolCommands {
         };
     }
 
+    public static IncomingDataBuffer createDataBuffer(IoStream stream, Logger logger) {
+        IncomingDataBuffer incomingData = new IncomingDataBuffer(logger);
+        stream.setInputListener(incomingData::addData);
+        return incomingData;
+    }
+
     public static void sleep(int millis) {
         try {
             Thread.sleep(millis);