rusefi
/
custom-board-bundle-sample-fork-of-rusefi
mirror of https://github.com/rusefi/custom-board-bundle-sample-fork-of-rusefi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Revert "proxy progress" 

This reverts commit 6e6fff16
This commit is contained in:
rusefi 2020-07-08 16:37:34 -04:00
parent 30b1c8ff18
commit a55715f369
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
java_console/io/src/main/java/com/rusefi/binaryprotocol/BinaryProtocol.java
View File

@ -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);