aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java
diff options
context:
space:
mode:
authorMichael Williamson <mike@zwobble.org>2016-03-26 09:27:45 +0000
committerMichael Williamson <mike@zwobble.org>2016-03-26 09:27:45 +0000
commitabbcc3915fa783c648436ef52e15da923a246dd1 (patch)
tree2db501fd1a82dc608217623cc53b8a6b13f71bb5 /src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java
parent55ec6fed7278825bee4b6db24965b69b9c496ed5 (diff)
Lazily combine warnings in results
Diffstat (limited to 'src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java')
-rw-r--r--src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java30
1 files changed, 30 insertions, 0 deletions
diff --git a/src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java b/src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java
index b9fd029..c0231e0 100644
--- a/src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java
+++ b/src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java
@@ -6,6 +6,8 @@ import java.util.Iterator;
import java.util.Optional;
import java.util.function.Function;
import java.util.function.Predicate;
+import java.util.stream.Stream;
+import java.util.stream.StreamSupport;
public class MammothIterables {
public static <T> Optional<T> tryGetLast(Iterable<T> iterable) {
@@ -39,6 +41,30 @@ public class MammothIterables {
}
}
+ public static <T, R> Iterable<R> lazyFlatMap(Iterable<T> iterable, Function<T, Iterable<R>> function) {
+ return lazyFlatten(lazyMap(iterable, function));
+ }
+
+ public static <T> Iterable<T> lazyConcat(Iterable<T> iterable1, Iterable<T> iterable2) {
+ return new Iterable<T>() {
+ @Override
+ public Iterator<T> iterator() {
+ return Stream.concat(stream(iterable1), stream(iterable2)).iterator();
+ }
+ };
+ }
+
+ public static <T> Iterable<T> lazyFlatten(Iterable<? extends Iterable<T>> iterables) {
+ return new Iterable<T>() {
+ @Override
+ public Iterator<T> iterator() {
+ return stream(iterables)
+ .flatMap(iterable -> stream(iterable))
+ .iterator();
+ }
+ };
+ }
+
private static <T, R> Iterator<R> map(Iterator<T> iterator, Function<T, R> function) {
return new Iterator<R>() {
@Override
@@ -52,4 +78,8 @@ public class MammothIterables {
}
};
}
+
+ public static <T> Stream<T> stream(Iterable<T> iterable) {
+ return StreamSupport.stream(iterable.spliterator(), false);
+ }
}