/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
D | DistinctOpTest.java | 80 public void testOp(String name, TestData.OfRef<Integer> data) { in testOp() 94 public void testOpWithNull(String name, TestData.OfRef<Integer> data) { in testOpWithNull() 108 public void testOpWithNullSorted(String name, TestData.OfRef<Integer> data) { in testOpWithNullSorted() 145 public void testDistinctDistinct(String name, TestData.OfRef<Integer> data) { in testDistinctDistinct() 157 public void testDistinctSorted(String name, TestData.OfRef<Integer> data) { in testDistinctSorted() 167 public void testSortedDistinct(String name, TestData.OfRef<Integer> data) { in testSortedDistinct()
|
D | ToArrayOpTest.java | 60 public void testOps(String name, TestData.OfRef<Integer> data) { in testOps() 65 public void testOpsWithMap(String name, TestData.OfRef<Integer> data) { in testOpsWithMap() 74 public void testOpsWithSorted(String name, TestData.OfRef<Integer> data) { in testOpsWithSorted() 83 public void testOpsWithFlatMap(String name, TestData.OfRef<Integer> data) { in testOpsWithFlatMap() 94 public void testOpsWithFilter(String name, TestData.OfRef<Integer> data) { in testOpsWithFilter() 120 public void testDistinctAndSortedPermutations(String name, TestData.OfRef<Integer> data) { in testDistinctAndSortedPermutations() 150 …private <T extends Object> ResultAsserter<T[]> statefulOpResultAsserter(TestData.OfRef<Integer> da… in statefulOpResultAsserter() 182 public void testStatefulOpPermutations(String name, TestData.OfRef<Integer> data) {
|
D | TabulatorsTest.java | 280 private<T, R> void assertCollect(TestData.OfRef<T> data, 288 …public void testReduce(String name, TestData.OfRef<Integer> data) throws ReflectiveOperationExcept… 337 …public void testJoin(String name, TestData.OfRef<Integer> data) throws ReflectiveOperationExceptio… 385 private<T> String join(TestData.OfRef<T> data, String delim) { 398 …public void testSimpleToMap(String name, TestData.OfRef<Integer> data) throws ReflectiveOperationE… 447 …public void testSimpleGroupBy(String name, TestData.OfRef<Integer> data) throws ReflectiveOperatio… 471 …public void testTwoLevelGroupBy(String name, TestData.OfRef<Integer> data) throws ReflectiveOperat… 527 …public void testGroupedReduce(String name, TestData.OfRef<Integer> data) throws ReflectiveOperatio… 576 …public void testSimplePartition(String name, TestData.OfRef<Integer> data) throws ReflectiveOperat… 589 …public void testTwoLevelPartition(String name, TestData.OfRef<Integer> data) throws ReflectiveOper… [all …]
|
D | SliceOpTest.java | 153 public void testSkipOps(String name, TestData.OfRef<Integer> data) { in testSkipOps() 176 public void testSkipLimitOps(String name, TestData.OfRef<Integer> data) { in testSkipLimitOps() 234 TestData.OfRef<Integer> data = TestData.Factory.ofSupplier( in testSkipLimitOpsWithNonSplittingSpliterator() 243 public void testLimitOps(String name, TestData.OfRef<Integer> data) { in testLimitOps() 286 private void testSliceMulti(TestData.OfRef<Integer> data, 303 private final void testSliceMulti(TestData.OfRef<Integer> data,
|
D | SequentialOpTest.java | 53 public void testLazy(String name, TestData.OfRef<Integer> data) { in testLazy() 99 public void testMixedSeqPar(String name, TestData.OfRef<Integer> data) { in testMixedSeqPar()
|
D | InfiniteStreamWithLimitOpTest.java | 136 private TestData.OfRef<Long> refLongs() { 140 private TestData.OfRef<Long> refLongRange(long l, long u) { 360 TestData.OfRef<Long> generator = TestData.Factory.ofSupplier( 407 TestData.OfRef<Long> iterator = TestData.Factory.ofSupplier(
|
D | FindFirstOpTest.java | 60 public void testStream(String name, TestData.OfRef<Integer> data) { in testStream() 67 … void exerciseStream(TestData.OfRef<Integer> data, Function<Stream<Integer>, Stream<Integer>> fs) { in exerciseStream()
|
D | GroupByOpTest.java | 110 List<MapperData<Integer, ?>> getMapperData(TestData.OfRef<Integer> data) { in getMapperData() 128 public void testOps(String name, TestData.OfRef<Integer> data) { in testOps()
|
D | FindAnyOpTest.java | 67 public void testStream(String name, TestData.OfRef<Integer> data) { in testStream() 74 … void exerciseStream(TestData.OfRef<Integer> data, Function<Stream<Integer>, Stream<Integer>> fs) { in exerciseStream()
|
D | ReduceByOpTest.java | 50 public void testOps(String name, TestData.OfRef<Integer> data) { in testOps()
|
D | CountTest.java | 51 public void testOps(String name, TestData.OfRef<Integer> data) { in testOps()
|
D | ForEachOpTest.java | 89 TestData.OfRef<Integer> data = TestData.Factory.ofCollection("[1, 10000]", input); 111 public void testForEach(String name, TestData.OfRef<Integer> data) {
|
D | StreamBuilderTest.java | 77 TestData.OfRef<Integer> data = TestData.Factory.ofSupplier("[0, 1)", in testSingleton() 121 TestData.OfRef<Integer> data = TestData.Factory.ofSupplier(String.format("[0, %d)", size), in testStreamBuilder()
|
D | ReduceTest.java | 61 public void testOps(String name, TestData.OfRef<Integer> data) { in testOps()
|
D | StreamLinkTest.java | 61 public void testManyStreams(String name, TestData.OfRef<Integer> data) {
|
D | MinMaxTest.java | 62 public void testOps(String name, TestData.OfRef<Integer> data) { in testOps()
|
/libcore/ojluni/src/main/java/java/util/stream/ |
D | Nodes.java | 67 private static final Node EMPTY_NODE = new EmptyNode.OfRef(); 325 new SizedCollectorTask.OfRef<>(spliterator, helper, array).invoke(); in collect() 328 Node<P_OUT> node = new CollectorTask.OfRef<>(helper, generator, spliterator).invoke(); in collect() 470 new ToArrayTask.OfRef<>(node, array, 0).invoke(); in flatten() 574 private static class OfRef<T> extends EmptyNode<T, T[], Consumer<? super T>> { class in Nodes.EmptyNode 575 private OfRef() { in OfRef() method in Nodes.EmptyNode.OfRef 788 return new Nodes.InternalNodeSpliterator.OfRef<>(this); in spliterator() 1058 private static final class OfRef<T> class in Nodes.InternalNodeSpliterator 1061 OfRef(Node<T> curNode) { in OfRef() method in Nodes.InternalNodeSpliterator.OfRef 1896 static final class OfRef<P_IN, P_OUT> [all …]
|
D | StreamSpliterators.java | 689 static final class OfRef<T> class in StreamSpliterators.AbstractWrappingSpliterator.SliceSpliterator 693 OfRef(Spliterator<T> s, long sliceOrigin, long sliceFence) { in OfRef() method in StreamSpliterators.AbstractWrappingSpliterator.SliceSpliterator.OfRef 697 private OfRef(Spliterator<T> s, in OfRef() method in StreamSpliterators.AbstractWrappingSpliterator.SliceSpliterator.OfRef 706 return new OfRef<>(s, sliceOrigin, sliceFence, origin, fence); in makeSpliterator() 991 static final class OfRef<T> extends UnorderedSliceSpliterator<T, Spliterator<T>> class in StreamSpliterators.AbstractWrappingSpliterator.UnorderedSliceSpliterator 995 OfRef(Spliterator<T> s, long skip, long limit) { in OfRef() method in StreamSpliterators.AbstractWrappingSpliterator.UnorderedSliceSpliterator.OfRef 999 OfRef(Spliterator<T> s, OfRef<T> parent) { in OfRef() method in StreamSpliterators.AbstractWrappingSpliterator.UnorderedSliceSpliterator.OfRef 1028 ArrayBuffer.OfRef<T> sb = null; in forEachRemaining() 1034 sb = new ArrayBuffer.OfRef<>(CHUNK_SIZE); in forEachRemaining() 1053 return new UnorderedSliceSpliterator.OfRef<>(s, this); in makeSpliterator() [all …]
|
D | SortedOps.java | 51 return new OfRef<>(upstream); in makeRef() 63 return new OfRef<>(upstream, comparator); in makeRef() 99 private static final class OfRef<T> extends ReferencePipeline.StatefulOp<T, T> { class in SortedOps 110 OfRef(AbstractPipeline<?, T, ?> upstream) { in OfRef() method in SortedOps.OfRef 125 OfRef(AbstractPipeline<?, T, ?> upstream, Comparator<? super T> comparator) { in OfRef() method in SortedOps.OfRef
|
D | ForEachOps.java | 73 return new ForEachOp.OfRef<>(action, ordered); in makeRef() 174 static final class OfRef<T> extends ForEachOp<T> { class in ForEachOps.ForEachOp 177 OfRef(Consumer<? super T> consumer, boolean ordered) { in OfRef() method in ForEachOps.ForEachOp.OfRef
|
D | FindOps.java | 59 Optional::isPresent, FindSink.OfRef::new); in makeRef() 190 static final class OfRef<T> extends FindSink<T, Optional<T>> { class in FindOps.FindSink
|
D | Stream.java | 1053 … new StreamSpliterators.InfiniteSupplyingSpliterator.OfRef<>(Long.MAX_VALUE, s), false); in generate() 1079 Spliterator<T> split = new Streams.ConcatSpliterator.OfRef<>( in concat()
|
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
D | TestData.java | 68 public interface OfRef<T> extends TestData<T, Stream<T>> { } interface 78 public static <T> OfRef<T> ofArray(String name, T[] array) { in ofArray() 83 public static <T> OfRef<T> ofCollection(String name, Collection<T> collection) { in ofCollection() 88 public static <T> OfRef<T> ofSpinedBuffer(String name, SpinedBuffer<T> buffer) { in ofSpinedBuffer() 96 public static <T> OfRef<T> ofSupplier(String name, Supplier<Stream<T>> supplier) { in ofSupplier() 104 public static <T> OfRef<T> ofRefNode(String name, Node<T> node) { in ofRefNode() 267 implements TestData.OfRef<T> {
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
D | TestData.java | 69 public interface OfRef<T> extends TestData<T, Stream<T>> { } interface 79 public static <T> OfRef<T> ofArray(String name, T[] array) { in ofArray() 84 public static <T> OfRef<T> ofCollection(String name, Collection<T> collection) { in ofCollection() 89 public static <T> OfRef<T> ofSpinedBuffer(String name, SpinedBuffer<T> buffer) { in ofSpinedBuffer() 97 public static <T> OfRef<T> ofSupplier(String name, Supplier<Stream<T>> supplier) { in ofSupplier() 105 public static <T> OfRef<T> ofRefNode(String name, Node<T> node) { in ofRefNode() 268 implements TestData.OfRef<T> {
|
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
D | SliceSpliteratorTest.java | 79 return new StreamSpliterators.SliceSpliterator.OfRef<>(s, skip, limit); in sliceSpliteratorDataProvider() 135 return new StreamSpliterators.UnorderedSliceSpliterator.OfRef<>(s, skip, limit); in sliceSpliteratorDataProvider()
|