summaryrefslogtreecommitdiff
path: root/base/src/main/java/bjc/utils/cli/StreamTerminal.java
diff options
context:
space:
mode:
authorBen Culkin <scorpress@gmail.com>2023-06-25 14:59:52 -0400
committerBen Culkin <scorpress@gmail.com>2023-06-25 14:59:52 -0400
commitc50f997a46cbd2c889a31750f9558847e80aac61 (patch)
tree85c942bf77e66876fb822f615afcd23a5cba70ea /base/src/main/java/bjc/utils/cli/StreamTerminal.java
parent29db46041115065559a0d42f9a76ebb7c19424ea (diff)
Add some documentation
Diffstat (limited to 'base/src/main/java/bjc/utils/cli/StreamTerminal.java')
-rw-r--r--base/src/main/java/bjc/utils/cli/StreamTerminal.java12
1 files changed, 12 insertions, 0 deletions
diff --git a/base/src/main/java/bjc/utils/cli/StreamTerminal.java b/base/src/main/java/bjc/utils/cli/StreamTerminal.java
index a45a22e..69be8d7 100644
--- a/base/src/main/java/bjc/utils/cli/StreamTerminal.java
+++ b/base/src/main/java/bjc/utils/cli/StreamTerminal.java
@@ -7,6 +7,12 @@ import java.util.*;
import java.util.concurrent.*;
import java.util.concurrent.locks.*;
+/**
+ * Implementation of {@link Terminal} using {@link Reader} and {@link Writer}
+ *
+ * @author bjcul
+ *
+ */
public class StreamTerminal implements Terminal, Runnable {
private SortedSet<Long> pendingRequests;
private ConcurrentMap<Long, String> pendingReplies;
@@ -23,6 +29,12 @@ public class StreamTerminal implements Terminal, Runnable {
private long currentRequest = -1;
+ /**
+ * Create a new stream terminal.
+ *
+ * @param input The input source
+ * @param output The output source
+ */
public StreamTerminal(Reader input, Writer output) {
this.inputScanner = new Scanner(input);
this.output = output;