summaryrefslogtreecommitdiff
path: root/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.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/SerialBlockReader.java
parentb3ac1c8690c3e14c879913e5dcc03a5f5e14876e (diff)
Start splitting into maven modules
Diffstat (limited to 'BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java')
-rw-r--r--BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java102
1 files changed, 0 insertions, 102 deletions
diff --git a/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java b/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
deleted file mode 100644
index c229da1..0000000
--- a/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
+++ /dev/null
@@ -1,102 +0,0 @@
-package bjc.utils.ioutils.blocks;
-
-import java.io.IOException;
-import java.util.Deque;
-
-/**
- * Provides a means of concatenating two block readers.
- *
- * @author bjculkin
- *
- */
-public class SerialBlockReader implements BlockReader {
- private Deque<BlockReader> readerQueue;
-
- private int blockNo;
-
- /**
- * Create a new serial block reader.
- *
- * @param readers
- * The readers to pull from, in the order to pull from
- * them.
- */
- public SerialBlockReader(final BlockReader... readers) {
- for (final BlockReader reader : readers) {
- readerQueue.add(reader);
- }
- }
-
- @Override
- public boolean hasNextBlock() {
- if (readerQueue.isEmpty()) return false;
-
- /*
- * Attempt to get a block from the first reader.
- */
- boolean hasBlock = readerQueue.peek().hasNextBlock();
- boolean cont = hasBlock || readerQueue.isEmpty();
-
- /*
- * Close/dispose of readers until we get an open one.
- */
- while (!cont) {
- try {
- readerQueue.pop().close();
- } catch (final IOException ioex) {
- throw new IllegalStateException("Exception thrown by discarded reader", ioex);
- }
-
- hasBlock = readerQueue.peek().hasNextBlock();
- cont = hasBlock || readerQueue.isEmpty();
- }
-
- return hasBlock;
- }
-
- @Override
- public Block getBlock() {
- if (readerQueue.isEmpty())
- return null;
- else return readerQueue.peek().getBlock();
- }
-
- @Override
- public boolean nextBlock() {
- if (readerQueue.isEmpty()) return false;
-
- boolean gotBlock = readerQueue.peek().nextBlock();
- boolean cont = gotBlock || readerQueue.isEmpty();
-
- while (!cont) {
- try {
- readerQueue.pop().close();
- } catch (final IOException ioex) {
- throw new IllegalStateException("Exception thrown by discarded reader", ioex);
- }
-
- gotBlock = readerQueue.peek().nextBlock();
- cont = gotBlock || readerQueue.isEmpty();
- }
-
- if (cont) {
- blockNo += 1;
- }
-
- return cont;
- }
-
- @Override
- public int getBlockCount() {
- return blockNo;
- }
-
- @Override
- public void close() throws IOException {
- while (!readerQueue.isEmpty()) {
- final BlockReader reader = readerQueue.pop();
-
- reader.close();
- }
- }
-}