1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
package org.zwobble.mammoth.internal.util;
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 Iterables {
public static <T> Optional<T> tryFind(Iterable<T> iterable, Predicate<T> predicate) {
for (T element : iterable) {
if (predicate.test(element)) {
return Optional.of(element);
}
}
return Optional.empty();
}
public static <T, R> Iterable<R> lazyMap(Iterable<T> iterable, Function<T, R> function) {
return new Iterable<R>() {
@Override
public Iterator<R> iterator() {
return map(iterable.iterator(), function);
}
};
}
public static <T> Optional<T> getFirst(Iterable<? extends T> iterable) {
Iterator<? extends T> iterator = iterable.iterator();
if (iterator.hasNext()) {
return Optional.of(iterator.next());
} else {
return Optional.empty();
}
}
public static <T> T getFirst(Iterable<? extends T> iterable, T defaultValue) {
Iterator<? extends T> iterator = iterable.iterator();
if (iterator.hasNext()) {
return iterator.next();
} else {
return defaultValue;
}
}
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();
}
};
}
public static <T> Iterable<T> lazyFilter(Iterable<T> iterables, Predicate<T> predicate) {
return new Iterable<T>() {
@Override
public Iterator<T> iterator() {
return stream(iterables)
.filter(predicate)
.iterator();
}
};
}
public static <T, R> Iterable<R> lazyFilter(Iterable<T> iterables, Class<R> clazz) {
return new Iterable<R>() {
@Override
@SuppressWarnings("unchecked")
public Iterator<R> iterator() {
return (Iterator<R>) stream(iterables)
.filter(clazz::isInstance)
.iterator();
}
};
}
private static <T, R> Iterator<R> map(Iterator<T> iterator, Function<T, R> function) {
return new Iterator<R>() {
@Override
public boolean hasNext() {
return iterator.hasNext();
}
@Override
public R next() {
return function.apply(iterator.next());
}
};
}
public static <T> boolean any(Iterable<T> iterable, Predicate<T> predicate) {
return stream(iterable).anyMatch(predicate);
}
public static <T> Stream<T> stream(Iterable<T> iterable) {
return StreamSupport.stream(iterable.spliterator(), false);
}
}
|
