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

refactoring

This commit is contained in:
rusefillc 2022-05-01 13:20:59 -04:00
parent 191256b10f
commit 44778db37b
1 changed files with 2 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
java_console/io/src/main/java/com/rusefi/io/stream/PCanIoStream.java
View File

@ -76,8 +76,6 @@ public class PCanIoStream extends AbstractIoStream {
// log.info("Send OK! length=" + payLoad.length);
}
private DataListener listener;
public PCanIoStream(PCANBasic can) {
this.can = can;
dataBuffer = createDataBuffer("");
@ -90,16 +88,15 @@ public class PCanIoStream extends AbstractIoStream {
@Override
public void setInputListener(DataListener listener) {
this.listener = listener;
Executor threadExecutor = Executors.newSingleThreadExecutor(BinaryProtocolServer.getThreadFactory("PCAN reader"));
threadExecutor.execute(() -> {
while (!isClosed()) {
readOnePacket();
readOnePacket(listener);
}
});
}
public void readOnePacket() {
private void readOnePacket(DataListener listener) {
// todo: can we reuse instance?
TPCANMsg rx = new TPCANMsg();
TPCANStatus status = can.Read(CHANNEL, rx, null);