summaryrefslogtreecommitdiff
path: root/base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
diff options
context:
space:
mode:
Diffstat (limited to 'base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java')
-rw-r--r--base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java26
1 files changed, 13 insertions, 13 deletions
diff --git a/base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java b/base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
index c229da1..62db3a8 100644
--- a/base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
+++ b/base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java
@@ -18,18 +18,17 @@ public class SerialBlockReader implements BlockReader {
* Create a new serial block reader.
*
* @param readers
- * The readers to pull from, in the order to pull from
- * them.
+ * The readers to pull from, in the order to pull from them.
*/
public SerialBlockReader(final BlockReader... readers) {
- for (final BlockReader reader : readers) {
+ for(final BlockReader reader : readers) {
readerQueue.add(reader);
}
}
@Override
public boolean hasNextBlock() {
- if (readerQueue.isEmpty()) return false;
+ if(readerQueue.isEmpty()) return false;
/*
* Attempt to get a block from the first reader.
@@ -40,10 +39,10 @@ public class SerialBlockReader implements BlockReader {
/*
* Close/dispose of readers until we get an open one.
*/
- while (!cont) {
+ while(!cont) {
try {
readerQueue.pop().close();
- } catch (final IOException ioex) {
+ } catch(final IOException ioex) {
throw new IllegalStateException("Exception thrown by discarded reader", ioex);
}
@@ -56,22 +55,23 @@ public class SerialBlockReader implements BlockReader {
@Override
public Block getBlock() {
- if (readerQueue.isEmpty())
+ if(readerQueue.isEmpty())
return null;
- else return readerQueue.peek().getBlock();
+ else
+ return readerQueue.peek().getBlock();
}
@Override
public boolean nextBlock() {
- if (readerQueue.isEmpty()) return false;
+ if(readerQueue.isEmpty()) return false;
boolean gotBlock = readerQueue.peek().nextBlock();
boolean cont = gotBlock || readerQueue.isEmpty();
- while (!cont) {
+ while(!cont) {
try {
readerQueue.pop().close();
- } catch (final IOException ioex) {
+ } catch(final IOException ioex) {
throw new IllegalStateException("Exception thrown by discarded reader", ioex);
}
@@ -79,7 +79,7 @@ public class SerialBlockReader implements BlockReader {
cont = gotBlock || readerQueue.isEmpty();
}
- if (cont) {
+ if(cont) {
blockNo += 1;
}
@@ -93,7 +93,7 @@ public class SerialBlockReader implements BlockReader {
@Override
public void close() throws IOException {
- while (!readerQueue.isEmpty()) {
+ while(!readerQueue.isEmpty()) {
final BlockReader reader = readerQueue.pop();
reader.close();