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

removing some dead code

This commit is contained in:
rusefillc 2022-05-01 13:19:26 -04:00
parent ef4bd1bf35
commit 3343c02a1d
2 changed files with 3 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
java_console/io/src/main/java/com/rusefi/io/can/Elm327Connector.java
View File

@ -51,7 +51,7 @@ public class Elm327Connector implements Closeable {
public Elm327Connector(IoStream underlyingStream) {
this.underlyingStream = underlyingStream;
underlyingStream.setInputListener(listener);
tsStream = new Elm327IoStream(this, "elm327Stream");
tsStream = new Elm327IoStream(this);
}
/**

19
java_console/io/src/main/java/com/rusefi/io/can/Elm327IoStream.java
View File

@ -15,7 +15,6 @@ import java.util.Arrays;
*/
public class Elm327IoStream extends AbstractIoStream {
private final Elm327Connector con;
private final DisconnectListener disconnectListener;
@NotNull
private final IncomingDataBuffer dataBuffer;
private DataListener dataListener;
@ -32,15 +31,9 @@ public class Elm327IoStream extends AbstractIoStream {
private final IsoTpCanDecoder canDecoder = new IsoTpCanDecoder();
public Elm327IoStream(Elm327Connector con, String loggingPrefix) {
this(con, loggingPrefix, DisconnectListener.VOID);
}
private Elm327IoStream(Elm327Connector con, String loggingPrefix, DisconnectListener disconnectListener) {
public Elm327IoStream(Elm327Connector con) {
this.con = con;
this.disconnectListener = disconnectListener;
dataBuffer = createDataBuffer(loggingPrefix);
dataBuffer = createDataBuffer("elm327Stream");
// ByteBuffer inBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE);
outBuf = ByteBuffer.allocate(OUT_BUFFER_SIZE);
@ -52,7 +45,6 @@ public class Elm327IoStream extends AbstractIoStream {
synchronized (this) {
if (!isClosed()) {
super.close();
disconnectListener.onDisconnect("on close");
}
}
}
@ -127,11 +119,4 @@ public class Elm327IoStream extends AbstractIoStream {
if (rawData.length != 0)
sendDataToClient(rawData);
}
public interface DisconnectListener {
DisconnectListener VOID = (String message) -> {
};
void onDisconnect(String message);
}
}