diff options
Diffstat (limited to 'base/src/test/java/bjc/utils')
| -rw-r--r-- | base/src/test/java/bjc/utils/test/cli/StreamTerminalTest.java | 16 |
1 files changed, 12 insertions, 4 deletions
diff --git a/base/src/test/java/bjc/utils/test/cli/StreamTerminalTest.java b/base/src/test/java/bjc/utils/test/cli/StreamTerminalTest.java index de300d2..c080d6f 100644 --- a/base/src/test/java/bjc/utils/test/cli/StreamTerminalTest.java +++ b/base/src/test/java/bjc/utils/test/cli/StreamTerminalTest.java @@ -3,7 +3,8 @@ package bjc.utils.test.cli; import static org.junit.Assert.*; import java.io.*; -import java.util.Scanner; +import java.util.*; +import java.util.function.Consumer; import org.junit.Test; @@ -36,7 +37,10 @@ public class StreamTerminalTest { InputStreamReader outPipeReader = new InputStreamReader(outPipeIn); OutputStreamWriter outPipeWriter = new OutputStreamWriter(outPipeOut); - StreamTerminal terminal = new StreamTerminal(inPipeReader, outPipeWriter); + List<String> repList = new ArrayList<>(); + Consumer<String> repAction = repList::add; + + StreamTerminal terminal = new StreamTerminal(inPipeReader, outPipeWriter, "/", repAction); long reqID1 = terminal.submitRequest("Request 1"); long reqID2 = terminal.submitRequest("Request 2"); @@ -45,8 +49,9 @@ public class StreamTerminalTest { assertEquals(1, reqID2); inPipeWriter.write("r 0,A\n"); - inPipeWriter.write("r 1,B\n"); - inPipeWriter.write("q\n"); + inPipeWriter.write("/r 0,A\n"); + inPipeWriter.write("/r 1,B\n"); + inPipeWriter.write("/q\n"); inPipeWriter.flush(); inPipeWriter.close(); @@ -75,6 +80,9 @@ public class StreamTerminalTest { assertEquals("A", terminal.awaitReply(reqID1)); assertEquals("B", terminal.awaitReply(reqID2)); + + assertEquals(1, repList.size()); + assertEquals("r 0,A", repList.get(0)); } catch (IOException ioex) { throw new RuntimeException(ioex); } catch (InterruptedException iex) { |