summaryrefslogtreecommitdiff
path: root/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java
diff options
context:
space:
mode:
authorBenjamin J. Culkin <bjculkin@mix.wvu.edu>2017-10-08 22:39:59 -0300
committerBenjamin J. Culkin <bjculkin@mix.wvu.edu>2017-10-08 22:39:59 -0300
commitc82e3b3b2de0633317ec8fc85925e91422820597 (patch)
tree96567416ce23c5ce85601f9cedc3a94bb1c55cba /BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java
parentb3ac1c8690c3e14c879913e5dcc03a5f5e14876e (diff)
Start splitting into maven modules
Diffstat (limited to 'BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java')
-rw-r--r--BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java106
1 files changed, 0 insertions, 106 deletions
diff --git a/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java b/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java
deleted file mode 100644
index 0cc9dea..0000000
--- a/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/PushbackBlockReader.java
+++ /dev/null
@@ -1,106 +0,0 @@
-package bjc.utils.ioutils.blocks;
-
-import java.io.IOException;
-import java.util.Deque;
-import java.util.LinkedList;
-
-/**
- * A block reader that supports pushing blocks onto the input queue so that they
- * are provided before blocks read from an input source.
- *
- * @author bjculkin
- *
- */
-public class PushbackBlockReader implements BlockReader {
- private final BlockReader source;
-
- /*
- * The queue of pushed-back blocks.
- */
- private final Deque<Block> waiting;
-
- private Block curBlock;
-
- private int blockNo;
-
- /**
- * Create a new pushback block reader.
- *
- * @param src
- * The block reader to use when no blocks are queued.
- */
- public PushbackBlockReader(final BlockReader src) {
- source = src;
-
- waiting = new LinkedList<>();
- }
-
- @Override
- public boolean hasNextBlock() {
- return !waiting.isEmpty() || source.hasNextBlock();
- }
-
- @Override
- public Block getBlock() {
- return curBlock;
- }
-
- @Override
- public boolean nextBlock() {
- /*
- * Drain pushed-back blocks first.
- */
- if (!waiting.isEmpty()) {
- curBlock = waiting.pop();
-
- blockNo += 1;
-
- return true;
- } else {
- final boolean succ = source.nextBlock();
- curBlock = source.getBlock();
-
- if (succ) {
- blockNo += 1;
- }
-
- return succ;
- }
- }
-
- @Override
- public int getBlockCount() {
- return blockNo;
- }
-
- @Override
- public void close() throws IOException {
- source.close();
- }
-
- /**
- * Insert a block at the back of the queue of pending blocks.
- *
- * @param blk
- * The block to put at the back.
- */
- public void addBlock(final Block blk) {
- waiting.add(blk);
- }
-
- /**
- * Insert a block at the front of the queue of pending blocks.
- *
- * @param blk
- * The block to put at the front.
- */
- public void pushBlock(final Block blk) {
- waiting.push(blk);
- }
-
- @Override
- public String toString() {
- return String.format("PushbackBlockReader [waiting=%s, curBlock=%s, blockNo=%s]", waiting, curBlock,
- blockNo);
- }
-}