summaryrefslogtreecommitdiff
path: root/base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java
diff options
context:
space:
mode:
authorbjculkin <bjculkin@mix.wvu.edu>2018-02-12 22:44:26 -0500
committerbjculkin <bjculkin@mix.wvu.edu>2018-02-12 22:44:26 -0500
commitae51c587c53f7ca311e556e3cbd0c5566d6c2843 (patch)
treea6bbb0baaa20300ad9949425455ea890c021d046 /base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java
parent32f5da54c628408c96db09d279f3a7ef44b3bd19 (diff)
Update
Diffstat (limited to 'base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java')
-rw-r--r--base/src/main/java/bjc/utils/ioutils/blocks/FlatMappedBlockReader.java18
1 files changed, 13 insertions, 5 deletions
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<Block> pending;
- private Block current;
+ private Iterator<Block> 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<Block, List<Block>> 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;