diff options
Diffstat (limited to 'base/src/main/java/bjc/utils/cli/StreamTerminal.java')
| -rw-r--r-- | base/src/main/java/bjc/utils/cli/StreamTerminal.java | 12 |
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; |