From 4e6854faa5706d02a74e0c04dc84a81aca58169a Mon Sep 17 00:00:00 2001 From: Ben Culkin Date: Wed, 9 Aug 2023 11:35:53 -0400 Subject: Add mode support --- .../test/java/bjc/utils/test/cli/StreamTerminalTest.java | 16 ++++++++++++---- 1 file changed, 12 insertions(+), 4 deletions(-) (limited to 'base/src/test/java/bjc') 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 repList = new ArrayList<>(); + Consumer 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) { -- cgit v1.2.3