diff options
| author | Michael Williamson <mike@zwobble.org> | 2016-03-26 09:27:45 +0000 |
|---|---|---|
| committer | Michael Williamson <mike@zwobble.org> | 2016-03-26 09:27:45 +0000 |
| commit | abbcc3915fa783c648436ef52e15da923a246dd1 (patch) | |
| tree | 2db501fd1a82dc608217623cc53b8a6b13f71bb5 /src/main/java/org/zwobble/mammoth/internal/util/MammothIterables.java | |
| parent | 55ec6fed7278825bee4b6db24965b69b9c496ed5 (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.java | 30 |
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); + } } |
