/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
D | IntNodeTest.java | 90 private Node.OfInt fill(int[] array, Node.Builder.OfInt nb) { in fill() 98 private Node.OfInt degenerateTree(PrimitiveIterator.OfInt it) { in degenerateTree() 105 return new Nodes.ConcNode.OfInt(Nodes.node(new int[] {i}), degenerateTree(it)); in degenerateTree() 112 private Node.OfInt tree(List<Integer> l, Function<List<Integer>, Node.OfInt> m) { in tree() 117 return new Nodes.ConcNode.OfInt( in tree() 124 public void testAsArray(int[] array, Node.OfInt n) { in testAsArray() 129 public void testFlattenAsArray(int[] array, Node.OfInt n) { in testFlattenAsArray() 134 public void testCopyTo(int[] array, Node.OfInt n) { in testCopyTo() 142 public void testForEach(int[] array, Node.OfInt n) { in testForEach() 152 public void testStreams(int[] array, Node.OfInt n) { in testStreams() [all …]
|
D | SpinedBufferTest.java | 153 SpinedBuffer.OfInt sb = new SpinedBuffer.OfInt(); in createIntSpinedBuffer() 163 public void testIntSpliterator(int[] array, SpinedBuffer.OfInt sb) { in testIntSpliterator() 171 public void testIntLastSplit(int[] array, SpinedBuffer.OfInt sb) { in testIntLastSplit() 172 Spliterator.OfInt spliterator = sb.spliterator(); in testIntLastSplit() 173 Spliterator.OfInt split = spliterator.trySplit(); in testIntLastSplit() 196 SpinedBuffer.OfInt sb = new SpinedBuffer.OfInt(); in testIntSpinedBuffer() 201 PrimitiveIterator.OfInt it = sb.iterator(); in testIntSpinedBuffer()
|
D | SliceSpliteratorTest.java | 90 … Spliterator.OfInt s = Arrays.spliterator(source.stream().mapToInt(i->i).toArray()); in sliceSpliteratorDataProvider() 92 return new StreamSpliterators.SliceSpliterator.OfInt(s, skip, limit); in sliceSpliteratorDataProvider() 147 … Spliterator.OfInt s = Arrays.spliterator(source.stream().mapToInt(i->i).toArray()); in sliceSpliteratorDataProvider() 149 return new StreamSpliterators.UnorderedSliceSpliterator.OfInt(s, skip, limit); in sliceSpliteratorDataProvider()
|
/libcore/ojluni/src/main/java/java/util/stream/ |
D | StreamSpliterators.java | 320 extends AbstractWrappingSpliterator<P_IN, Integer, SpinedBuffer.OfInt> 321 implements Spliterator.OfInt { 342 SpinedBuffer.OfInt b = new SpinedBuffer.OfInt(); in initPartialTraversalState() 344 bufferSink = ph.wrapSink((Sink.OfInt) b::accept); in initPartialTraversalState() 349 public Spliterator.OfInt trySplit() { in trySplit() 350 return (Spliterator.OfInt) super.trySplit(); in trySplit() 368 ph.wrapAndCopyInto((Sink.OfInt) consumer::accept, spliterator); in forEachRemaining() 575 static final class OfInt class in StreamSpliterators.AbstractWrappingSpliterator.DelegatingSpliterator 576 extends OfPrimitive<Integer, IntConsumer, Spliterator.OfInt> 577 implements Spliterator.OfInt { [all …]
|
D | Nodes.java | 68 private static final Node.OfInt EMPTY_INT_NODE = new EmptyNode.OfInt(); 126 return (Node<T>) new ConcNode.OfInt((Node.OfInt) left, (Node.OfInt) right); in conc() 200 static Node.OfInt node(int[] array) { in node() 212 static Node.Builder.OfInt intBuilder(long exactSizeIfKnown) { in intBuilder() 223 static Node.Builder.OfInt intBuilder() { in intBuilder() 362 public static <P_IN> Node.OfInt collectInt(PipelineHelper<Integer> helper, in collectInt() 370 new SizedCollectorTask.OfInt<>(spliterator, helper, array).invoke(); in collectInt() 374 Node.OfInt node = new CollectorTask.OfInt<>(helper, spliterator).invoke(); in collectInt() 498 public static Node.OfInt flattenInt(Node.OfInt node) { in flattenInt() 504 new ToArrayTask.OfInt(node, array, 0).invoke(); in flattenInt() [all …]
|
D | IntStream.java | 198 SpinedBuffer.OfInt buffer = new SpinedBuffer.OfInt(); in mapMulti() 378 new WhileOps.UnorderedWhileSpliterator.OfInt.Taking(spliterator(), true, predicate), in takeWhile() 444 … new WhileOps.UnorderedWhileSpliterator.OfInt.Dropping(spliterator(), true, predicate), in dropWhile() 876 PrimitiveIterator.OfInt iterator(); in iterator() 879 Spliterator.OfInt spliterator(); in spliterator() 945 Spliterator.OfInt spliterator = new Spliterators.AbstractIntSpliterator(Long.MAX_VALUE, in iterate() 1007 Spliterator.OfInt spliterator = new Spliterators.AbstractIntSpliterator(Long.MAX_VALUE, in iterate() 1059 … new StreamSpliterators.InfiniteSupplyingSpliterator.OfInt(Long.MAX_VALUE, s), false); in generate() 1151 Spliterator.OfInt split = new Streams.ConcatSpliterator.OfInt( in concat()
|
D | Node.java | 207 interface OfInt extends Node.Builder<Integer>, Sink.OfInt { interface 209 Node.OfInt build(); in build() 319 interface OfInt extends OfPrimitive<Integer, IntConsumer, int[], Spliterator.OfInt, OfInt> { interface 361 default Node.OfInt truncate(long from, long to, IntFunction<Integer[]> generator) { in truncate() 365 Spliterator.OfInt spliterator = spliterator(); in truncate() 366 Node.Builder.OfInt nodeBuilder = Nodes.intBuilder(size); in truncate()
|
D | WhileOps.java | 134 return new UnorderedWhileSpliterator.OfInt.Taking( 135 … (Spliterator.OfInt) helper.wrapSpliterator(spliterator), false, predicate); 438 return new UnorderedWhileSpliterator.OfInt.Dropping( 439 … (Spliterator.OfInt) helper.wrapSpliterator(spliterator), false, predicate); 847 …abstract static class OfInt extends UnorderedWhileSpliterator<Integer, Spliterator.OfInt> implemen… 851 OfInt(Spliterator.OfInt s, boolean noSplitting, IntPredicate p) { 856 OfInt(Spliterator.OfInt s, UnorderedWhileSpliterator.OfInt parent) { 867 static final class Taking extends UnorderedWhileSpliterator.OfInt { 868 Taking(Spliterator.OfInt s, boolean noSplitting, IntPredicate p) { 872 Taking(Spliterator.OfInt s, UnorderedWhileSpliterator.OfInt parent) { [all …]
|
D | Streams.java | 54 static final class RangeIntSpliterator implements Spliterator.OfInt { 131 public Spliterator.OfInt trySplit() { in trySplit() 418 extends AbstractStreamBuilderImpl<Integer, Spliterator.OfInt> 419 implements IntStream.Builder, Spliterator.OfInt { 426 SpinedBuffer.OfInt buffer; 453 buffer = new SpinedBuffer.OfInt(); in accept() 807 static class OfInt class in Streams 808 extends ConcatSpliterator.OfPrimitive<Integer, IntConsumer, Spliterator.OfInt> 809 implements Spliterator.OfInt { 810 OfInt(Spliterator.OfInt aSpliterator, Spliterator.OfInt bSpliterator) { in OfInt() method in Streams.OfInt
|
D | FindOps.java | 71 return mustFindFirst ? FindSink.OfInt.OP_FIND_FIRST : FindSink.OfInt.OP_FIND_ANY; in makeInt() 207 static final class OfInt extends FindSink<Integer, OptionalInt> class in FindOps.FindSink 208 implements Sink.OfInt { 222 OptionalInt::isPresent, FindSink.OfInt::new); 225 OptionalInt::isPresent, FindSink.OfInt::new);
|
D | IntPipeline.java | 119 private static Spliterator.OfInt adapt(Spliterator<Integer> s) { in adapt() 120 if (s instanceof Spliterator.OfInt) { in adapt() 121 return (Spliterator.OfInt) s; in adapt() 160 …public final Spliterator.OfInt lazySpliterator(Supplier<? extends Spliterator<Integer>> supplier) { in lazySpliterator() 161 … return new StreamSpliterators.DelegatingSpliterator.OfInt((Supplier<Spliterator.OfInt>) supplier); in lazySpliterator() 167 Spliterator.OfInt spl = adapt(spliterator); in forEachWithCancel() 199 public final PrimitiveIterator.OfInt iterator() { 204 public final Spliterator.OfInt spliterator() { 580 return Nodes.flattenInt((Node.OfInt) evaluateToArrayNode(Integer[]::new))
|
D | SliceOps.java | 85 … -> new StreamSpliterators.SliceSpliterator.OfInt((Spliterator.OfInt) s, skip, sliceFence); in sliceSpliterator() 242 Spliterator.OfInt unorderedSkipLimitSpliterator( 243 Spliterator.OfInt s, long skip, long limit, long sizeIfKnown) { 250 return new StreamSpliterators.UnorderedSliceSpliterator.OfInt(s, skip, limit); 259 return new StreamSpliterators.SliceSpliterator.OfInt( 260 (Spliterator.OfInt) helper.wrapSpliterator(spliterator), 265 (Spliterator.OfInt) helper.wrapSpliterator(spliterator), 289 Spliterator.OfInt s = unorderedSkipLimitSpliterator( 290 (Spliterator.OfInt) helper.wrapSpliterator(spliterator),
|
D | SortedOps.java | 73 return new OfInt(upstream); in makeInt() 167 private static final class OfInt extends IntPipeline.StatefulOp<Integer> { class in SortedOps 168 OfInt(AbstractPipeline<?, Integer, ?> upstream) { in OfInt() method in SortedOps.OfInt 193 Node.OfInt n = (Node.OfInt) helper.evaluate(spliterator, true, generator); in opEvaluateParallel() 475 private SpinedBuffer.OfInt b; 485 b = (size > 0) ? new SpinedBuffer.OfInt((int) size) : new SpinedBuffer.OfInt(); in begin()
|
/libcore/ojluni/src/test/java/util/BitSet/stream/ |
D | BitSetStreamTest.java | 125 PrimitiveIterator.OfInt it = bs.stream().iterator(); in testBitsetStream() 176 …tNullPointerException(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntNullPointerException() 182 …c void testIntForEach(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntForEach() 187 …oid testIntTryAdvance(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntTryAdvance() 192 …ixedTryAdvanceForEach(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntMixedTryAdvanceForEach() 197 …MixedTraverseAndSplit(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntMixedTraverseAndSplit() 202 …litAfterFullTraversal(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntSplitAfterFullTraversal() 207 …void testIntSplitOnce(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntSplitOnce() 212 …d testIntSplitSixDeep(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntSplitSixDeep() 217 …testIntSplitUntilNull(String description, Collection<Integer> exp, Supplier<Spliterator.OfInt> s) { in testIntSplitUntilNull()
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
D | TestData.java | 71 public interface OfInt extends TestData<Integer, IntStream> { } interface 114 public static <T> OfInt ofArray(String name, int[] array) { in ofArray() 119 public static OfInt ofSpinedBuffer(String name, SpinedBuffer.OfInt buffer) { in ofSpinedBuffer() 123 SpinedBuffer.OfInt::spliterator, in ofSpinedBuffer() 127 public static OfInt ofIntSupplier(String name, Supplier<IntStream> supplier) { in ofIntSupplier() 135 public static OfInt ofNode(String name, Node.OfInt node) { in ofNode() 140 Node.OfInt::spliterator, in ofNode() 282 extends AbstractTestData<Integer, IntStream, I, Spliterator.OfInt> 283 implements TestData.OfInt { 289 Function<I, Spliterator.OfInt> splitrFn, in IntTestData() [all …]
|
D | IntStreamTestDataProvider.java | 93 SpinedBuffer.OfInt isl = new SpinedBuffer.OfInt(); 114 SpinedBuffer.OfInt isl = new SpinedBuffer.OfInt(); 147 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfInt> s) { in splitDescr()
|
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
D | TestData.java | 70 public interface OfInt extends TestData<Integer, IntStream> { } interface 113 public static <T> OfInt ofArray(String name, int[] array) { in ofArray() 118 public static OfInt ofSpinedBuffer(String name, SpinedBuffer.OfInt buffer) { in ofSpinedBuffer() 122 SpinedBuffer.OfInt::spliterator, in ofSpinedBuffer() 126 public static OfInt ofIntSupplier(String name, Supplier<IntStream> supplier) { in ofIntSupplier() 134 public static OfInt ofNode(String name, Node.OfInt node) { in ofNode() 139 Node.OfInt::spliterator, in ofNode() 281 extends AbstractTestData<Integer, IntStream, I, Spliterator.OfInt> 282 implements TestData.OfInt { 288 Function<I, Spliterator.OfInt> splitrFn, in IntTestData() [all …]
|
D | IntStreamTestDataProvider.java | 89 SpinedBuffer.OfInt isl = new SpinedBuffer.OfInt(); 110 SpinedBuffer.OfInt isl = new SpinedBuffer.OfInt(); 143 static <T> Object[] splitDescr(String description, Supplier<Spliterator.OfInt> s) { in splitDescr()
|
D | CollectorOps.java | 95 public static class OfInt extends TestParallelSizedOp<Integer> { class in CollectorOps.TestParallelSizedOp 96 public OfInt() { in OfInt() method in CollectorOps.TestParallelSizedOp.OfInt
|
/libcore/ojluni/src/main/java/java/util/ |
D | Spliterators.java | 75 public static Spliterator.OfInt emptyIntSpliterator() { in emptyIntSpliterator() 79 private static final Spliterator.OfInt EMPTY_INT_SPLITERATOR = 80 new EmptySpliterator.OfInt(); 204 public static Spliterator.OfInt spliterator(int[] array, in spliterator() 237 public static Spliterator.OfInt spliterator(int[] array, int fromIndex, int toIndex, in spliterator() 505 public static Spliterator.OfInt spliterator(PrimitiveIterator.OfInt iterator, in spliterator() 533 public static Spliterator.OfInt spliteratorUnknownSize(PrimitiveIterator.OfInt iterator, in spliteratorUnknownSize() 725 public static PrimitiveIterator.OfInt iterator(Spliterator.OfInt spliterator) { in iterator() 727 class Adapter implements PrimitiveIterator.OfInt, IntConsumer { in iterator() 911 private static final class OfInt class in Spliterators.EmptySpliterator [all …]
|
D | Spliterator.java | 662 public interface OfInt extends OfPrimitive<Integer, IntConsumer, OfInt> { interface 665 OfInt trySplit(); in trySplit()
|
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
D | StreamSpliteratorTest.java | 122 …private static class OfInt extends ProxyNoExactSizeSpliterator<Integer> implements Spliterator.OfI… class in StreamSpliteratorTest.ProxyNoExactSizeSpliterator 123 final Spliterator.OfInt psp; 125 private OfInt(Spliterator.OfInt sp, boolean proxyEstimateSize) { in OfInt() method in StreamSpliteratorTest.ProxyNoExactSizeSpliterator.OfInt 131 public Spliterator.OfInt trySplit() { in trySplit() 133 Spliterator.OfInt prefix = psp.trySplit(); in trySplit() 141 return Spliterator.OfInt.super.tryAdvance(consumer); in tryAdvance() 146 Spliterator.OfInt.super.forEachRemaining(consumer); in forEachRemaining() 368 … Spliterator.OfInt sp = intermediateOp.apply(IntStream.range(0, 1000)).spliterator(); in testIntSplitting() 369 …ProxyNoExactSizeSpliterator.OfInt psp = new ProxyNoExactSizeSpliterator.OfInt(sp, proxyEstimateSiz… in testIntSplitting() 389 public void testIntStreamSpliterators(String name, TestData.OfInt data) { [all …]
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/ |
D | SpliteratorOfIntDataBuilder.java | 39 public void add(String description, List<Integer> expected, Supplier<Spliterator.OfInt> s) { in add() 44 public void add(String description, Supplier<Spliterator.OfInt> s) { in add()
|
/libcore/ojluni/src/main/java/java/nio/ |
D | CharBufferSpliterator.java | 39 class CharBufferSpliterator implements Spliterator.OfInt { 56 public OfInt trySplit() { in trySplit()
|
/libcore/luni/src/test/java/libcore/java/util/ |
D | SpliteratorsTest.java | 41 Spliterator.OfInt empty = Spliterators.emptyIntSpliterator(); in testEmptyIntSpliterator() 218 Spliterator.OfInt intSp = Spliterators.spliterator(elements, 0); in test_spliterator_int() 231 Spliterator.OfInt split1 = intSp.trySplit(); in test_spliterator_int() 237 Spliterator.OfInt split2 = split1.trySplit(); in test_spliterator_int() 254 Spliterator.OfInt sp = Spliterators.spliterator(elements, 2, 6, 0); in test_spliterator_intOffsetBasic() 367 Spliterator.OfInt intSp = Spliterators.spliterator(elements, 0); in test_primitive_spliterators_NPE() 523 private static class CannedIntPrimitiveIterator implements PrimitiveIterator.OfInt { 587 PrimitiveIterator.OfInt elements = new CannedIntPrimitiveIterator(data); in test_spliterator_intPrimitiveIterator() 588 Spliterator.OfInt intSp = Spliterators.spliterator(elements, 16 /* size */, 0); in test_spliterator_intPrimitiveIterator() 601 Spliterator.OfInt split1 = intSp.trySplit(); in test_spliterator_intPrimitiveIterator() [all …]
|