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

proxy progress

This commit is contained in:
rusefi 2020-07-08 16:30:31 -04:00
parent 98f0f145d5
commit 06f9faccf5
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
java_console/io/src/main/java/com/rusefi/io/tcp/TcpIoStream.java
View File

@ -56,9 +56,8 @@ public class TcpIoStream implements IoStream {
@Override
public void setInputListener(final DataListener listener) {
ByteReader reader = buffer -> input.read(buffer);
ByteReader.runReaderLoop(listener, reader, logger);
ByteReader.runReaderLoop(listener, input::read, logger);
}
@Override

6
java_console/ui/src/test/java/com/rusefi/io/TcpCommunicationIntegrationTest.java
View File

@ -78,7 +78,7 @@ public class TcpCommunicationIntegrationTest {
System.out.println("Failed");
}
});
assertTrue(connectionEstablishedCountDownLatch.await(30, TimeUnit.SECONDS));
assertTrue("Connection established", connectionEstablishedCountDownLatch.await(30, TimeUnit.SECONDS));
assertEquals(0, server.unknownCommands.get());
@ -112,7 +112,7 @@ public class TcpCommunicationIntegrationTest {
CountDownLatch connectionEstablishedCountDownLatch = new CountDownLatch(1);
LinkManager clientManager = new LinkManager(LOGGER);
clientManager.startAndConnect(Integer.toString(proxyPort), new ConnectionStateListener() {
clientManager.startAndConnect(LOCALHOST + ":" + proxyPort, new ConnectionStateListener() {
@Override
public void onConnectionEstablished() {
connectionEstablishedCountDownLatch.countDown();
@ -123,7 +123,7 @@ public class TcpCommunicationIntegrationTest {
System.out.println("Failed");
}
});
assertTrue(connectionEstablishedCountDownLatch.await(30, TimeUnit.SECONDS));
assertTrue("Connection established", connectionEstablishedCountDownLatch.await(30, TimeUnit.SECONDS));
clientManager.stop();
}