diff options
| author | Michael Williamson <mike@zwobble.org> | 2016-04-02 14:52:21 +0100 |
|---|---|---|
| committer | Michael Williamson <mike@zwobble.org> | 2016-04-02 14:52:21 +0100 |
| commit | 7fccda0f13f6f8b7f7a1f6e87a648fe1c3396656 (patch) | |
| tree | 3b73a695446faaff9e50232584815e7ef50d9e9c /src/main/java/org/zwobble/couscous/util/ExtraIterables.java | |
| parent | def25b112080df902121b09a35c02d1fe7728386 (diff) | |
Use JSON to configure CLI
Diffstat (limited to 'src/main/java/org/zwobble/couscous/util/ExtraIterables.java')
| -rw-r--r-- | src/main/java/org/zwobble/couscous/util/ExtraIterables.java | 17 |
1 files changed, 11 insertions, 6 deletions
diff --git a/src/main/java/org/zwobble/couscous/util/ExtraIterables.java b/src/main/java/org/zwobble/couscous/util/ExtraIterables.java index cd9b3df..a77869d 100644 --- a/src/main/java/org/zwobble/couscous/util/ExtraIterables.java +++ b/src/main/java/org/zwobble/couscous/util/ExtraIterables.java @@ -5,6 +5,7 @@ import com.google.common.collect.Iterables; import java.util.Iterator; import java.util.function.BiFunction; import java.util.function.Function; +import java.util.function.Supplier; import java.util.stream.Stream; import java.util.stream.StreamSupport; @@ -105,15 +106,19 @@ public class ExtraIterables { } public static <T, R> Iterable<R> lazyFlatMap(Iterable<T> iterable, Function<T, Iterable<R>> function) { - return new Iterable<R>() { - @Override - public Iterator<R> iterator() { - return stream(iterable).flatMap(element -> stream(function.apply(element))).iterator(); - } - }; + return iterable(() -> stream(iterable).flatMap(element -> stream(function.apply(element)))); } public static <T> Stream<T> stream(Iterable<T> iterable) { return StreamSupport.stream(iterable.spliterator(), false); } + + public static <T, E> Iterable<T> iterable(Supplier<Stream<T>> stream) { + return new Iterable<T>() { + @Override + public Iterator<T> iterator() { + return stream.get().iterator(); + } + }; + } } |
