X-Git-Url: https://git.pterodactylus.net/?a=blobdiff_plain;f=src%2Ftest%2Fjava%2Fnet%2Fpterodactylus%2Ffcp%2Ffake%2FFakeTcpServer.java;h=67a1fdcd6e0df73a7663606ca6e4951eba5e804b;hb=5f80d791d840300e127f06281d8c432a7071887d;hp=6b3674a13f603211900ca97dccf75d7d0ad41f58;hpb=8edbf10b2a4cbc3e43853c9c042a1f40500c94be;p=jFCPlib.git diff --git a/src/test/java/net/pterodactylus/fcp/fake/FakeTcpServer.java b/src/test/java/net/pterodactylus/fcp/fake/FakeTcpServer.java index 6b3674a..67a1fdc 100644 --- a/src/test/java/net/pterodactylus/fcp/fake/FakeTcpServer.java +++ b/src/test/java/net/pterodactylus/fcp/fake/FakeTcpServer.java @@ -31,12 +31,9 @@ public class FakeTcpServer implements AutoCloseable { } public Future connect() throws IOException { - return executorService.submit(new Callable() { - @Override - public Void call() throws Exception { - clientSocket.set(new TextSocket(serverSocket.accept())); - return null; - } + return executorService.submit(() -> { + clientSocket.set(new TextSocket(serverSocket.accept())); + return null; }); } @@ -44,8 +41,10 @@ public class FakeTcpServer implements AutoCloseable { return clientSocket.get().collectUntil(lineMatcher); } - public void writeLine(String line) throws IOException { - clientSocket.get().writeLine(line); + public void writeLine(String... lines) throws IOException { + for (String line : lines) { + clientSocket.get().writeLine(line); + } } public String readLine() throws IOException {