summaryrefslogtreecommitdiff
path: root/base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java
diff options
context:
space:
mode:
Diffstat (limited to 'base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java')
-rw-r--r--base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java20
1 files changed, 17 insertions, 3 deletions
diff --git a/base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java b/base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java
index 12fa848..72da16d 100644
--- a/base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java
+++ b/base/src/main/java/bjc/utils/ioutils/blocks/MappedBlockReader.java
@@ -4,6 +4,12 @@ import java.io.IOException;
import java.util.function.UnaryOperator;
+/**
+ * A block reader that applies a transform to each block.
+ *
+ * @author EVE
+ *
+ */
public class MappedBlockReader implements BlockReader {
private BlockReader reader;
@@ -13,8 +19,16 @@ public class MappedBlockReader implements BlockReader {
private int blockNo;
+ /**
+ * Create a new mapped block reader.
+ *
+ * @param source
+ * The source for blocks
+ * @param trans
+ * The transform to apply.
+ */
public MappedBlockReader(BlockReader source, UnaryOperator<Block> trans) {
- reader = source;
+ reader = source;
transform = trans;
blockNo = 0;
@@ -30,10 +44,10 @@ public class MappedBlockReader implements BlockReader {
return current;
}
- @Override
+ @Override
public boolean nextBlock() {
if(hasNextBlock()) {
- current = transform.apply(reader.next());
+ current = transform.apply(reader.next());
blockNo += 1;
return true;