refactoring
This commit is contained in:
parent
ad83e0ad05
commit
4fb92fe6fd
|
@ -66,13 +66,7 @@ public class BinaryProtocol implements BinaryProtocolCommands {
|
||||||
this.stream = stream;
|
this.stream = stream;
|
||||||
|
|
||||||
incomingData = new IncomingDataBuffer(logger);
|
incomingData = new IncomingDataBuffer(logger);
|
||||||
DataListener streamDataListener = new DataListener() {
|
stream.setInputListener(incomingData::addData);
|
||||||
@Override
|
|
||||||
public void onDataArrived(byte[] freshData) {
|
|
||||||
incomingData.addData(freshData);
|
|
||||||
}
|
|
||||||
};
|
|
||||||
stream.setInputListener(streamDataListener);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void sleep() {
|
private static void sleep() {
|
||||||
|
|
Loading…
Reference in New Issue