From ae51c587c53f7ca311e556e3cbd0c5566d6c2843 Mon Sep 17 00:00:00 2001 From: bjculkin Date: Mon, 12 Feb 2018 22:44:26 -0500 Subject: Update --- .../utils/ioutils/blocks/FlatMappedBlockReader.java | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) (limited to 'base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java') diff --git a/base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java b/base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java index 16d2e44..bab463e 100644 --- a/base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java +++ b/base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java @@ -22,8 +22,8 @@ public class FlatMappedBlockReader implements BlockReader { /* * The current block, and any blocks pending from the last source block. */ - private Iterator pending; - private Block current; + private Iterator pending; + private Block current; /* * The operator to open blocks with. @@ -35,8 +35,16 @@ public class FlatMappedBlockReader implements BlockReader { */ private int blockNo; + /** + * Create a new flat-mapping block reader. + * + * @param source + * The source to read blocks from + * @param trans + * The transform to use. + */ public FlatMappedBlockReader(BlockReader source, Function> trans) { - reader = source; + reader = source; transform = trans; blockNo = 0; @@ -52,7 +60,7 @@ public class FlatMappedBlockReader implements BlockReader { return current; } - @Override + @Override public boolean nextBlock() { /* * Attempt to get a new pending list if the one we have isn't @@ -67,7 +75,7 @@ public class FlatMappedBlockReader implements BlockReader { /* * Advance the iterator. */ - current = pending.next(); + current = pending.next(); blockNo += 1; return true; -- cgit v1.2.3