From df94066e3af02ff02d5ab4d033a3d603f743234c Mon Sep 17 00:00:00 2001 From: bjculkin Date: Mon, 12 Feb 2018 22:45:04 -0500 Subject: Formatting pass --- .../utils/ioutils/blocks/SerialBlockReader.java | 26 +++++++++++----------- 1 file changed, 13 insertions(+), 13 deletions(-) (limited to 'base/src/main/java/bjc/utils/ioutils/blocks/SerialBlockReader.java') 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(); -- cgit v1.2.3