| /libcore/ojluni/src/main/java/java/util/stream/ |
| AbstractShortCircuitTask.java | 27 import java.util.Spliterator;
65 * @param spliterator the {@code Spliterator} describing the source for this
69 Spliterator<P_IN> spliterator) {
70 super(helper, spliterator);
78 * @param spliterator the {@code Spliterator} for the portion of the
82 Spliterator<P_IN> spliterator) {
[all...] |
| FindOps.java | 31 import java.util.Spliterator;
151 Spliterator<S> spliterator) {
152 O result = helper.wrapAndCopyInto(sinkSupplier.get(), spliterator).get();
158 Spliterator<P_IN> spliterator) {
159 return new FindTask<>(this, helper, spliterator).invoke();
256 Spliterator<P_IN> spliterator) {
257 super(helper, spliterator);
[all...] |
| MatchOps.java | 28 import java.util.Spliterator;
229 Spliterator<S> spliterator) {
230 return helper.wrapAndCopyInto(sinkSupplier.get(), spliterator).getAndClearState();
235 Spliterator<S> spliterator) {
242 return new MatchTask<>(this, helper, spliterator).invoke();
286 Spliterator<P_IN> spliterator) {
287 super(helper, spliterator);
[all...] |
| BaseStream.java | 30 import java.util.Spliterator;
75 * Returns a spliterator for the elements of this stream.
80 * @return the element spliterator for this stream
82 Spliterator<T> spliterator(); method in interface:BaseStream
|
| StreamSpliterators.java | 29 import java.util.Spliterator;
43 * Spliterator implementations for wrapping and delegating spliterators, used
44 * in the implementation of the {@link Stream#spliterator()} method.
51 * Abstract wrapping spliterator that binds to the spliterator of a
54 * <p>This spliterator is not late-binding and will bind to the source
55 * spliterator when first operated on.
57 * <p>A wrapping spliterator produced from a sequential stream
62 implements Spliterator<P_OUT> {
68 * True if this spliterator supports splittin
84 Spliterator<P_IN> spliterator; field in class:StreamSpliterators.AbstractWrappingSpliterator
[all...] |
| DoubleStream.java | 34 import java.util.Spliterator;
714 Spliterator.OfDouble spliterator(); method in interface:DoubleStream
[all...] |
| SortedOps.java | 31 import java.util.Spliterator;
148 Spliterator<P_IN> spliterator,
153 return helper.evaluate(spliterator, false, generator);
157 T[] flattenedData = helper.evaluate(spliterator, true, generator).asArray(generator);
187 Spliterator<P_IN> spliterator,
190 return helper.evaluate(spliterator, false, generator);
193 Node.OfInt n = (Node.OfInt) helper.evaluate(spliterator, true, generator);
226 Spliterator<P_IN> spliterator
[all...] |
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| IntStreamTestDataProvider.java | 116 () -> Arrays.spliterator(ints)));
118 () -> Arrays.spliterator(ints, 0, ints.length / 2)));
121 () -> isl.spliterator()));
124 () -> Spliterators.spliterator(isl.iterator(), ints.length, 0)));
129 () -> IntStream.range(0, ints.length).spliterator()));
131 () -> IntStream.rangeClosed(0, ints.length).spliterator()));
143 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfInt> s) {
|
| LongStreamTestDataProvider.java | 116 () -> Arrays.spliterator(longs)));
118 () -> Arrays.spliterator(longs, 0, longs.length / 2)));
121 () -> isl.spliterator()));
124 () -> Spliterators.spliterator(isl.iterator(), longs.length, 0)));
129 () -> LongStream.range(0, longs.length).spliterator()));
131 () -> LongStream.rangeClosed(0, longs.length).spliterator()));
143 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfLong> s) {
|
| DoubleStreamTestDataProvider.java | 111 () -> Arrays.spliterator(doubles)));
113 () -> Arrays.spliterator(doubles, 0, doubles.length / 2)));
116 () -> isl.spliterator()));
119 () -> Spliterators.spliterator(isl.iterator(), doubles.length, 0)));
129 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfDouble> s) {
|
| DoubleStreamTestScenario.java | 29 import java.util.Spliterator;
79 for (Spliterator.OfDouble spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
88 SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
96 m.apply(data.stream()).spliterator().forEachRemaining(b);
120 for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
141 // Wrap as parallel stream, get the spliterator, wrap as a stream + toArray
146 Spliterator.OfDouble sp = s.spliterator()
[all...] |
| IntStreamTestScenario.java | 29 import java.util.Spliterator;
79 for (Spliterator.OfInt spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
88 SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
96 m.apply(data.stream()).spliterator().forEachRemaining(b);
120 for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
141 // Wrap as parallel stream, get the spliterator, wrap as a stream + toArray
146 Spliterator.OfInt sp = s.spliterator()
[all...] |
| LongStreamTestScenario.java | 29 import java.util.Spliterator;
79 for (Spliterator.OfLong spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
88 SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
96 m.apply(data.stream()).spliterator().forEachRemaining(b);
120 for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
141 // Wrap as parallel stream, get the spliterator, wrap as a stream + toArray
146 Spliterator.OfLong sp = s.spliterator()
[all...] |
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| IntStreamTestDataProvider.java | 117 () -> Arrays.spliterator(ints)));
119 () -> Arrays.spliterator(ints, 0, ints.length / 2)));
122 () -> isl.spliterator()));
125 () -> Spliterators.spliterator(isl.iterator(), ints.length, 0)));
130 () -> IntStream.range(0, ints.length).spliterator()));
132 () -> IntStream.rangeClosed(0, ints.length).spliterator()));
144 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfInt> s) {
|
| LongStreamTestDataProvider.java | 117 () -> Arrays.spliterator(longs)));
119 () -> Arrays.spliterator(longs, 0, longs.length / 2)));
122 () -> isl.spliterator()));
125 () -> Spliterators.spliterator(isl.iterator(), longs.length, 0)));
130 () -> LongStream.range(0, longs.length).spliterator()));
132 () -> LongStream.rangeClosed(0, longs.length).spliterator()));
144 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfLong> s) {
|
| DoubleStreamTestDataProvider.java | 112 () -> Arrays.spliterator(doubles)));
114 () -> Arrays.spliterator(doubles, 0, doubles.length / 2)));
117 () -> isl.spliterator()));
120 () -> Spliterators.spliterator(isl.iterator(), doubles.length, 0)));
130 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfDouble> s) {
|
| DoubleStreamTestScenario.java | 29 import java.util.Spliterator;
83 for (Spliterator.OfDouble spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
92 SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
100 m.apply(data.stream()).spliterator().forEachRemaining(b);
124 for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
133 m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
145 // Wrap as parallel stream, get the spliterator, wrap as a stream + toArray
150 Spliterator.OfDouble sp = s.spliterator()
[all...] |
| IntStreamTestScenario.java | 29 import java.util.Spliterator;
82 for (Spliterator.OfInt spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
91 SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
99 m.apply(data.stream()).spliterator().forEachRemaining(b);
123 for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
132 m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
144 // Wrap as parallel stream, get the spliterator, wrap as a stream + toArray
149 Spliterator.OfInt sp = s.spliterator()
[all...] |
| LongStreamTestScenario.java | 29 import java.util.Spliterator;
82 for (Spliterator.OfLong spl = m.apply(data.stream()).spliterator(); spl.tryAdvance(b); ) {
91 SpliteratorTestHelper.mixedTraverseAndSplit(b, m.apply(data.stream()).spliterator());
99 m.apply(data.stream()).spliterator().forEachRemaining(b);
123 for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) {
132 m.apply(data.parallelStream()).spliterator().forEachRemaining(b);
144 // Wrap as parallel stream, get the spliterator, wrap as a stream + toArray
149 Spliterator.OfLong sp = s.spliterator()
[all...] |
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| ConcatTest.java | 37 import java.util.Spliterator;
119 assertTrue(s1s.spliterator().hasCharacteristics(Spliterator.ORDERED), c1.getClass().toString());
120 assertTrue(s1p.spliterator().hasCharacteristics(Spliterator.ORDERED), c2.getClass().toString());
121 assertTrue(s2s.spliterator().hasCharacteristics(Spliterator.ORDERED), c1.getClass().toString());
122 assertTrue(s2p.spliterator().hasCharacteristics(Spliterator.ORDERED), c2.getClass().toString());
125 private <T> void assertConcatContent(Spliterator<T> sp, boolean ordered, Spliterator<T> expected)
[all...] |
| StreamSpliteratorTest.java | 37 import java.util.Spliterator;
65 private static class ProxyNoExactSizeSpliterator<T> implements Spliterator<T> {
66 final Spliterator<T> sp;
73 ProxyNoExactSizeSpliterator(Spliterator<T> sp, boolean proxyEstimateSize) {
79 public Spliterator<T> trySplit() {
81 Spliterator<T> prefix = sp.trySplit();
115 return sp.characteristics() & ~(Spliterator.SUBSIZED | Spliterator.SIZED);
118 private static class OfInt extends ProxyNoExactSizeSpliterator<Integer> implements Spliterator.OfInt {
119 final Spliterator.OfInt psp
[all...] |
| /libcore/ojluni/src/main/java/java/util/ |
| SortedSet.java | 224 * Creates a {@code Spliterator} over the elements in this sorted set.
226 * <p>The {@code Spliterator} reports {@link Spliterator#DISTINCT},
227 * {@link Spliterator#SORTED} and {@link Spliterator#ORDERED}.
231 * <p>The spliterator's comparator (see
232 * {@link java.util.Spliterator#getComparator()}) must be {@code null} if
234 * Otherwise, the spliterator's comparator must be the same as or impose the
239 * <em><a href="Spliterator.html#binding">late-binding</a></em> spliterator
255 default Spliterator<E> spliterator() { method in interface:SortedSet
[all...] |
| List.java | 604 * Creates a {@link Spliterator} over the elements in this list.
606 * <p>The {@code Spliterator} reports {@link Spliterator#SIZED} and
607 * {@link Spliterator#ORDERED}. Implementations should document the
612 * <em><a href="Spliterator.html#binding">late-binding</a></em> spliterator
613 * from the list's {@code Iterator}. The spliterator inherits the
617 * The created {@code Spliterator} additionally reports
618 * {@link Spliterator#SUBSIZED}.
620 * @return a {@code Spliterator} over the elements in this lis
624 default Spliterator<E> spliterator() { method in interface:List
[all...] |
| Spliterators.java | 34 * {@link Spliterator} and its primitive specializations
35 * {@link Spliterator.OfInt}, {@link Spliterator.OfLong}, and
36 * {@link Spliterator.OfDouble}.
38 * @see Spliterator
49 * Creates an empty {@code Spliterator}
51 * <p>The empty spliterator reports {@link Spliterator#SIZED} and
52 * {@link Spliterator#SUBSIZED}. Calls to
53 * {@link java.util.Spliterator#trySplit()} always return {@code null}
140 public static <T> Spliterator<T> spliterator(Object[] array, method in class:Spliterators
175 public static <T> Spliterator<T> spliterator(Object[] array, int fromIndex, int toIndex, method in class:Spliterators
204 public static Spliterator.OfInt spliterator(int[] array, method in class:Spliterators
237 public static Spliterator.OfInt spliterator(int[] array, int fromIndex, int toIndex, method in class:Spliterators
266 public static Spliterator.OfLong spliterator(long[] array, method in class:Spliterators
303 public static Spliterator.OfLong spliterator(long[] array, int fromIndex, int toIndex, method in class:Spliterators
332 public static Spliterator.OfDouble spliterator(double[] array, method in class:Spliterators
369 public static Spliterator.OfDouble spliterator(double[] array, int fromIndex, int toIndex, method in class:Spliterators
418 public static <T> Spliterator<T> spliterator(Collection<? extends T> c, method in class:Spliterators
448 public static <T> Spliterator<T> spliterator(Iterator<? extends T> iterator, method in class:Spliterators
505 public static Spliterator.OfInt spliterator(PrimitiveIterator.OfInt iterator, method in class:Spliterators
562 public static Spliterator.OfLong spliterator(PrimitiveIterator.OfLong iterator, method in class:Spliterators
619 public static Spliterator.OfDouble spliterator(PrimitiveIterator.OfDouble iterator, method in class:Spliterators
[all...] |
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| SliceSpliteratorTest.java | 32 import java.util.Spliterator;
70 // SIZED/SUBSIZED slice spliterator
77 Spliterator<Integer> s = Arrays.spliterator(source.stream().toArray(Integer[]::new));
90 Spliterator.OfInt s = Arrays.spliterator(source.stream().mapToInt(i->i).toArray());
103 Spliterator.OfLong s = Arrays.spliterator(source.stream().mapToLong(i->i).toArray());
116 Spliterator.OfDouble s = Arrays.spliterator(source.stream().mapToDouble(i->i).toArray())
[all...] |
