aboutsummaryrefslogtreecommitdiff
path: root/src/main/java/org/zwobble/couscous/util/ExtraIterables.java
diff options
context:
space:
mode:
authorMichael Williamson <mike@zwobble.org>2016-04-02 14:52:21 +0100
committerMichael Williamson <mike@zwobble.org>2016-04-02 14:52:21 +0100
commit7fccda0f13f6f8b7f7a1f6e87a648fe1c3396656 (patch)
tree3b73a695446faaff9e50232584815e7ef50d9e9c /src/main/java/org/zwobble/couscous/util/ExtraIterables.java
parentdef25b112080df902121b09a35c02d1fe7728386 (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.java17
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();
+ }
+ };
+ }
}