summaryrefslogtreecommitdiff
path: root/BJC-Utils2/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
diff options
context:
space:
mode:
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();
- }
- }
-}