Fix AsyncEchoTest
This commit is contained in:
parent
1736f681ef
commit
ec56e7f86c
@ -56,6 +56,7 @@ public class AsyncEchoClient {
|
|||||||
readResult.get();
|
readResult.get();
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
e.printStackTrace();
|
e.printStackTrace();
|
||||||
|
}
|
||||||
String echo = new String(buffer.array()).trim();
|
String echo = new String(buffer.array()).trim();
|
||||||
buffer.clear();
|
buffer.clear();
|
||||||
return echo;
|
return echo;
|
||||||
@ -73,7 +74,7 @@ public class AsyncEchoClient {
|
|||||||
AsyncEchoClient client = AsyncEchoClient.getInstance();
|
AsyncEchoClient client = AsyncEchoClient.getInstance();
|
||||||
client.start();
|
client.start();
|
||||||
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
|
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
|
||||||
String line = null;
|
String line;
|
||||||
System.out.println("Message to server:");
|
System.out.println("Message to server:");
|
||||||
while ((line = br.readLine()) != null) {
|
while ((line = br.readLine()) != null) {
|
||||||
String response = client.sendMessage(line);
|
String response = client.sendMessage(line);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user