1 | // License: GPL. For details, see LICENSE file.
|
---|
2 | package org.openstreetmap.josm.tools;
|
---|
3 |
|
---|
4 | import java.util.EnumSet;
|
---|
5 | import java.util.Iterator;
|
---|
6 | import java.util.Set;
|
---|
7 | import java.util.Spliterator;
|
---|
8 | import java.util.Spliterators;
|
---|
9 | import java.util.function.BiConsumer;
|
---|
10 | import java.util.function.BinaryOperator;
|
---|
11 | import java.util.function.Function;
|
---|
12 | import java.util.function.Supplier;
|
---|
13 | import java.util.stream.Collector;
|
---|
14 | import java.util.stream.Stream;
|
---|
15 | import java.util.stream.StreamSupport;
|
---|
16 |
|
---|
17 | /**
|
---|
18 | * Utility methods for streams.
|
---|
19 | * @author Michael Zangl
|
---|
20 | * @since 10585
|
---|
21 | */
|
---|
22 | public final class StreamUtils {
|
---|
23 |
|
---|
24 | private static final class HtmlListCollector implements Collector<String, StringBuilder, String> {
|
---|
25 | @Override
|
---|
26 | public Supplier<StringBuilder> supplier() {
|
---|
27 | return StringBuilder::new;
|
---|
28 | }
|
---|
29 |
|
---|
30 | @Override
|
---|
31 | public BiConsumer<StringBuilder, String> accumulator() {
|
---|
32 | return (sb, item) -> sb.append("<li>").append(item).append("</li>");
|
---|
33 | }
|
---|
34 |
|
---|
35 | @Override
|
---|
36 | public BinaryOperator<StringBuilder> combiner() {
|
---|
37 | return StringBuilder::append;
|
---|
38 | }
|
---|
39 |
|
---|
40 | @Override
|
---|
41 | public Function<StringBuilder, String> finisher() {
|
---|
42 | return sb -> "<ul>" + sb.toString() + "</ul>";
|
---|
43 | }
|
---|
44 |
|
---|
45 | @Override
|
---|
46 | public Set<Characteristics> characteristics() {
|
---|
47 | return EnumSet.of(Characteristics.CONCURRENT);
|
---|
48 | }
|
---|
49 | }
|
---|
50 |
|
---|
51 | /**
|
---|
52 | * Utility class
|
---|
53 | */
|
---|
54 | private StreamUtils() {}
|
---|
55 |
|
---|
56 | /**
|
---|
57 | * Convert an iterator to a stream.
|
---|
58 | * @param <T> The element type to iterate over
|
---|
59 | * @param iterator The iterator
|
---|
60 | * @return The stream of for that iterator.
|
---|
61 | */
|
---|
62 | public static <T> Stream<T> toStream(Iterator<? extends T> iterator) {
|
---|
63 | Spliterator<T> spliterator = Spliterators.spliteratorUnknownSize(iterator, Spliterator.ORDERED);
|
---|
64 | return StreamSupport.stream(spliterator, false);
|
---|
65 | }
|
---|
66 |
|
---|
67 | /**
|
---|
68 | * Creates a new Collector that collects the items and returns them as HTML unordered list.
|
---|
69 | * @return The collector.
|
---|
70 | * @since 10638
|
---|
71 | */
|
---|
72 | public static Collector<String, ?, String> toHtmlList() {
|
---|
73 | return new HtmlListCollector();
|
---|
74 | }
|
---|
75 | }
|
---|