andreika-git
/
rusefi
mirror of https://github.com/andreika-git/rusefi.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

progress

This commit is contained in:
rusefi 2020-05-31 12:51:53 -04:00
parent 8a3ccbc242
commit bd588c0bf2
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -20,7 +20,6 @@ import jssc.SerialPortException;
import org.jetbrains.annotations.Nullable;
import java.io.EOFException;
import java.io.FileWriter;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.ByteOrder;
@ -99,11 +98,16 @@ public class BinaryProtocol implements BinaryProtocolCommands {
this.logger = logger;
this.stream = stream;
incomingData = new IncomingDataBuffer(logger);
stream.setInputListener(incomingData::addData);
incomingData = createDataBuffer(stream, logger);
}
private static void sleep(int millis) {
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);
} catch (InterruptedException e) {