summaryrefslogtreecommitdiff
path: root/BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java
diff options
context:
space:
mode:
authorBenjamin J. Culkin <bjculkin@mix.wvu.edu>2017-10-08 22:39:59 -0300
committerBenjamin J. Culkin <bjculkin@mix.wvu.edu>2017-10-08 22:39:59 -0300
commitc82e3b3b2de0633317ec8fc85925e91422820597 (patch)
tree96567416ce23c5ce85601f9cedc3a94bb1c55cba /BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java
parentb3ac1c8690c3e14c879913e5dcc03a5f5e14876e (diff)
Start splitting into maven modules
Diffstat (limited to 'BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java')
-rw-r--r--BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java62
1 files changed, 0 insertions, 62 deletions
diff --git a/BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java b/BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java
deleted file mode 100644
index f3b2254..0000000
--- a/BJC-Utils2/src/main/java/bjc/utils/funcutils/GroupPartIteration.java
+++ /dev/null
@@ -1,62 +0,0 @@
-package bjc.utils.funcutils;
-
-import java.util.function.Consumer;
-import java.util.function.Function;
-
-import bjc.utils.funcdata.FunctionalList;
-import bjc.utils.funcdata.IList;
-
-/**
- * Implements a single group partitioning pass on a list
- *
- * @author ben
- *
- * @param <E>
- * The type of element in the list being partitioned
- */
-final class GroupPartIteration<E> implements Consumer<E> {
- private final IList<IList<E>> returnedList;
-
- public IList<E> currentPartition;
- private final IList<E> rejectedItems;
-
- private int numberInCurrentPartition;
- private final int numberPerPartition;
-
- private final Function<E, Integer> elementCounter;
-
- public GroupPartIteration(final IList<IList<E>> returned, final IList<E> rejects, final int nPerPart,
- final Function<E, Integer> eleCount) {
- this.returnedList = returned;
- this.rejectedItems = rejects;
- this.numberPerPartition = nPerPart;
- this.elementCounter = eleCount;
-
- this.currentPartition = new FunctionalList<>();
- this.numberInCurrentPartition = 0;
- }
-
- @Override
- public void accept(final E value) {
- final boolean shouldStartPartition = numberInCurrentPartition >= numberPerPartition;
-
- if (shouldStartPartition) {
- returnedList.add(currentPartition);
-
- currentPartition = new FunctionalList<>();
- numberInCurrentPartition = 0;
- } else {
- final int currentElementCount = elementCounter.apply(value);
-
- final boolean shouldReject = numberInCurrentPartition
- + currentElementCount >= numberPerPartition;
-
- if (shouldReject) {
- rejectedItems.add(value);
- } else {
- currentPartition.add(value);
- numberInCurrentPartition += currentElementCount;
- }
- }
- }
-}