Home
last modified time | relevance | path

Searched refs:collect (Results 1 – 25 of 29) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DSummaryStatisticsTest.java47 instances.add(countTo(1000).stream().collect(Collectors.summarizingInt(i -> i))); in testIntStatistics()
49 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingInt(i -> i))); in testIntStatistics()
62 instances.add(countTo(1000).stream().collect(Collectors.summarizingLong(i -> i))); in testLongStatistics()
64 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingLong(i -> i))); in testLongStatistics()
77 instances.add(countTo(1000).stream().collect(Collectors.summarizingDouble(i -> i))); in testDoubleStatistics()
79 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingDouble(i -> i))); in testDoubleStatistics()
DTabulatorsTest.java100 assertContentsUnordered(map.keySet(), source.get().map(classifier).collect(toSet())); in assertValue()
128 Set<K> uniqueKeys = source.get().map(keyFn).collect(toSet()); in assertValue()
253 .terminal(s -> s.collect(collector))
259 .terminal(s -> s.unordered().collect(collector))
284 withData(data).terminal(s -> s.collect(collector)).expectedResult(check).exercise();
339 .terminal(s -> s.map(Object::toString).collect(Collectors.joining()))
345 .terminal(s -> s.map(Object::toString).collect(likeJoining))
350 .terminal(s -> s.map(Object::toString).collect(Collectors.joining(",")))
355 .terminal(s -> s.map(Object::toString).collect(Collectors.joining(",", "[", "]")))
361 … .collect(StringBuilder::new, StringBuilder::append, StringBuilder::append)
[all …]
DGroupByOpTest.java85 …Map<Boolean,List<Integer>> result = countTo(10).stream().collect(Collectors.groupingBy(LambdaTestH… in testGroupBy()
137 .terminal(s -> s, s -> s.collect(tab)) in testOps()
DStreamBuilderTest.java126 expectedResult(IntStream.range(0, size).boxed().collect(toList())). in testStreamBuilder()
131 expectedResult(IntStream.range(0, size).boxed().collect(toList())). in testStreamBuilder()
DStreamLinkTest.java64 … List<Integer> expected = data.stream().map(e -> (Integer) (e + n)).collect(Collectors.toList());
DIntPrimitiveOpsTests.java78 List<Integer> l = IntStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
DLongPrimitiveOpsTests.java78 List<Long> l = LongStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
DDistinctOpTest.java181 .collect(Collectors.toList()); in testStable()
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/
DFillableStringTest.java43 String s = generate().collect(Collectors.joining()); in testStringBuilder()
48 String s = generate().collect(Collectors.joining()); in testStringBuffer()
53 String s = generate().collect(Collectors.joining("-")); in testStringJoiner()
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DSliceSpliteratorTest.java74 … final Collection<Integer> source = IntStream.range(0, size).boxed().collect(toList()); in sliceSpliteratorDataProvider()
87 … final Collection<Integer> source = IntStream.range(0, size).boxed().collect(toList()); in sliceSpliteratorDataProvider()
100 … final Collection<Long> source = LongStream.range(0, size).boxed().collect(toList()); in sliceSpliteratorDataProvider()
113 … Collection<Double> source = LongStream.range(0, size).asDoubleStream().boxed().collect(toList()); in sliceSpliteratorDataProvider()
129 … final Collection<Integer> source = IntStream.range(0, size).boxed().collect(toList()); in sliceSpliteratorDataProvider()
143 … final Collection<Integer> source = IntStream.range(0, size).boxed().collect(toList()); in sliceSpliteratorDataProvider()
157 … final Collection<Long> source = LongStream.range(0, size).boxed().collect(toList()); in sliceSpliteratorDataProvider()
171 … Collection<Double> source = LongStream.range(0, size).asDoubleStream().boxed().collect(toList()); in sliceSpliteratorDataProvider()
DSpinedBufferTest.java49 .collect(Collectors.toList());
113 .collect(Collectors.toList()); in testLastSplit()
188 .collect(Collectors.toList()); in testIntLastSplit()
263 .collect(Collectors.toList()); in testLongLastSplit()
339 .collect(Collectors.toList()); in testLongLastSplit()
DStreamOpFlagsTest.java119 … = StreamOpFlagTestHelper.allStreamFlags().stream().map(StreamOpFlag::set).collect(toList()); in testPairSet()
138 … = StreamOpFlagTestHelper.allStreamFlags().stream().map(StreamOpFlag::set).collect(toList()); in testPairSetAndClear()
/libcore/ojluni/src/test/java/util/stream/
DTestDoubleSumAverage.java79 DoubleSummaryStatistics stats = ds.get().collect(DoubleSummaryStatistics::new, in testForCompenstation()
92 … ds.get().boxed().collect(Collectors.summingDouble(d -> d)), 3); in testForCompenstation()
94 … ds.get().boxed().collect(Collectors.averagingDouble(d -> d)),3); in testForCompenstation()
128 DoubleSummaryStatistics stats = ds.get().collect(DoubleSummaryStatistics::new, in testNonfiniteSum()
138 …failures += compareUlpDifference(expected, ds.get().boxed().collect(Collectors.summingDouble(d -> … in testNonfiniteSum()
139 …failures += compareUlpDifference(expected, ds.get().boxed().collect(Collectors.averagingDouble(d -… in testNonfiniteSum()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStreamTestScenario.java64 for (U t : m.apply(data.stream()).collect(Collectors.toList())) { in STREAM_COLLECT()
186 for (U u : m.apply(data.parallelStream()).collect(Collectors.toList())) in PAR_STREAM_COLLECT_TO_LIST()
195 for (U u : m.apply(data.stream().parallel()).collect(Collectors.toList())) in STREAM_TO_PAR_STREAM_COLLECT_TO_LIST()
204 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) in PAR_STREAM_TO_STREAM_COLLECT_TO_LIST()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStreamTestScenario.java61 for (U t : m.apply(data.stream()).collect(Collectors.toList())) { in STREAM_COLLECT()
183 for (U u : m.apply(data.parallelStream()).collect(Collectors.toList())) in PAR_STREAM_COLLECT_TO_LIST()
192 for (U u : m.apply(data.stream().parallel()).collect(Collectors.toList())) in STREAM_TO_PAR_STREAM_COLLECT_TO_LIST()
201 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) in PAR_STREAM_TO_STREAM_COLLECT_TO_LIST()
/libcore/ojluni/src/main/java/java/util/stream/
DIntPipeline.java451 long[] avg = collect(() -> new long[2],
467 return collect(IntSummaryStatistics::new, IntSummaryStatistics::accept,
482 public final <R> R collect(Supplier<R> supplier,
DLongPipeline.java428 long[] avg = collect(() -> new long[2],
449 return collect(LongSummaryStatistics::new, LongSummaryStatistics::accept,
464 public final <R> R collect(Supplier<R> supplier,
DDoubleStream.java453 <R> R collect(Supplier<R> supplier, in collect() method
DIntStream.java445 <R> R collect(Supplier<R> supplier, in collect() method
DLongStream.java450 <R> R collect(Supplier<R> supplier, in collect() method
DSliceOps.java173 return Nodes.collect(helper, s, true, generator); in makeRef()
182 return Nodes.collect(this, s, true, generator); in makeRef()
/libcore/luni/src/test/java/libcore/java/util/
DArraysTest.java597 .collect(Collectors.toList()); in streamInt()
684 .collect(Collectors.toList()); in streamLong()
771 .collect(Collectors.toList()); in streamDouble()
857 .collect(Collectors.toList()); in streamObject()
DLocaleLanguageRangeTest.java434 return languageRanges.stream().map(LanguageRange::getRange).collect(Collectors.toList()); in rangesToStrings()
/libcore/luni/src/test/java/libcore/libcore/reflect/
DParameterizedTypeRegressionTest.java260 .collect(Collectors.toList()); in toString()
/libcore/luni/src/test/java/libcore/java/lang/invoke/
DMethodHandleCombinersTest.java1904 MethodHandle collect = MethodHandles.collectArguments(target, 2, filter); in testCollectArgumentsMultiThreaded() local
1905 collect = MethodHandles.insertArguments(collect, 0, "a", "b", 'c', 'd'); in testCollectArgumentsMultiThreaded()
1909 invokeMultiThreaded(MethodHandles.insertArguments(mh, 0, collect, "a: a, b: b, c: c+d")); in testCollectArgumentsMultiThreaded()

12