dead code
This commit is contained in:
parent
23e6ea5475
commit
5a9aeb0118
|
@ -265,7 +265,6 @@ public class BinaryProtocol implements BinaryProtocolCommands {
|
|||
if (isClosed)
|
||||
return;
|
||||
incomingData.dropPending();
|
||||
stream.purge();
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
@ -48,9 +48,4 @@ public interface IoStream extends WriteStream {
|
|||
boolean isClosed();
|
||||
|
||||
void close();
|
||||
|
||||
/**
|
||||
* purges pending input and output
|
||||
*/
|
||||
void purge();
|
||||
}
|
||||
|
|
|
@ -67,11 +67,6 @@ public class SerialIoStreamJSerialComm implements IoStream {
|
|||
logger.info(port + ": Closed port.");
|
||||
}
|
||||
|
||||
@Override
|
||||
public void purge() {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void write(byte[] bytes) {
|
||||
sp.writeBytes(bytes, bytes.length);
|
||||
|
|
|
@ -49,11 +49,6 @@ public class TcpIoStream implements IoStream {
|
|||
output.flush();
|
||||
}
|
||||
|
||||
@Override
|
||||
public void purge() {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public void setInputListener(final DataListener listener) {
|
||||
linkManager.TCP_READ_EXECUTOR.execute(new Runnable() {
|
||||
|
|
Loading…
Reference in New Issue