summaryrefslogtreecommitdiff
path: root/BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java
diff options
context:
space:
mode:
authorbjculkin <bjculkin@mix.wvu.edu>2017-04-06 14:14:37 -0400
committerbjculkin <bjculkin@mix.wvu.edu>2017-04-06 14:14:37 -0400
commit25382427eeafda30aa06a27f37c65fdaf8b67eba (patch)
tree109a2c5c4cd74ce47b961710952a26520bc17f90 /BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java
parent622653daa9e991e9608852210034a4e09cb94167 (diff)
Reorganize blocks
Diffstat (limited to 'BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java')
-rw-r--r--BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java98
1 files changed, 0 insertions, 98 deletions
diff --git a/BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java b/BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java
deleted file mode 100644
index d67e01a..0000000
--- a/BJC-Utils2/src/main/java/bjc/utils/ioutils/PushbackBlockReader.java
+++ /dev/null
@@ -1,98 +0,0 @@
-package bjc.utils.ioutils;
-
-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 BlockReader source;
-
- private 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(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() {
- if (!waiting.isEmpty()) {
- curBlock = waiting.pop();
-
- blockNo += 1;
-
- return true;
- } else {
- 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(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(Block blk) {
- waiting.push(blk);
- }
-
- @Override
- public String toString() {
- return String.format("PushbackBlockReader [waiting=%s, curBlock=%s, blockNo=%s]", waiting, curBlock,
- blockNo);
- }
-} \ No newline at end of file