test/java/util/stream/test/org/openjdk/tests/java/util/stream/SummaryStatisticsTest.java

Print this page
rev 7597 : 8015318: Extend Collector with 'finish' operation
Reviewed-by:
Contributed-by: brian.goetz@oracle.com

*** 41,53 **** */ @Test public class SummaryStatisticsTest extends OpTestCase { public void testIntStatistics() { List<IntSummaryStatistics> instances = new ArrayList<>(); ! instances.add(countTo(1000).stream().collect(Collectors.toIntSummaryStatistics(i -> i))); instances.add(countTo(1000).stream().mapToInt(i -> i).summaryStatistics()); ! instances.add(countTo(1000).parallelStream().collect(Collectors.toIntSummaryStatistics(i -> i))); instances.add(countTo(1000).parallelStream().mapToInt(i -> i).summaryStatistics()); for (IntSummaryStatistics stats : instances) { assertEquals(stats.getCount(), 1000); assertEquals(stats.getSum(), countTo(1000).stream().mapToInt(i -> i).sum()); --- 41,53 ---- */ @Test public class SummaryStatisticsTest extends OpTestCase { public void testIntStatistics() { List<IntSummaryStatistics> instances = new ArrayList<>(); ! instances.add(countTo(1000).stream().collect(Collectors.summarizingInt(i -> i))); instances.add(countTo(1000).stream().mapToInt(i -> i).summaryStatistics()); ! instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingInt(i -> i))); instances.add(countTo(1000).parallelStream().mapToInt(i -> i).summaryStatistics()); for (IntSummaryStatistics stats : instances) { assertEquals(stats.getCount(), 1000); assertEquals(stats.getSum(), countTo(1000).stream().mapToInt(i -> i).sum());
*** 56,68 **** } } public void testLongStatistics() { List<LongSummaryStatistics> instances = new ArrayList<>(); ! instances.add(countTo(1000).stream().collect(Collectors.toLongSummaryStatistics(i -> i))); instances.add(countTo(1000).stream().mapToLong(i -> i).summaryStatistics()); ! instances.add(countTo(1000).parallelStream().collect(Collectors.toLongSummaryStatistics(i -> i))); instances.add(countTo(1000).parallelStream().mapToLong(i -> i).summaryStatistics()); for (LongSummaryStatistics stats : instances) { assertEquals(stats.getCount(), 1000); assertEquals(stats.getSum(), (long) countTo(1000).stream().mapToInt(i -> i).sum()); --- 56,68 ---- } } public void testLongStatistics() { List<LongSummaryStatistics> instances = new ArrayList<>(); ! instances.add(countTo(1000).stream().collect(Collectors.summarizingLong(i -> i))); instances.add(countTo(1000).stream().mapToLong(i -> i).summaryStatistics()); ! instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingLong(i -> i))); instances.add(countTo(1000).parallelStream().mapToLong(i -> i).summaryStatistics()); for (LongSummaryStatistics stats : instances) { assertEquals(stats.getCount(), 1000); assertEquals(stats.getSum(), (long) countTo(1000).stream().mapToInt(i -> i).sum());
*** 71,83 **** } } public void testDoubleStatistics() { List<DoubleSummaryStatistics> instances = new ArrayList<>(); ! instances.add(countTo(1000).stream().collect(Collectors.toDoubleSummaryStatistics(i -> i))); instances.add(countTo(1000).stream().mapToDouble(i -> i).summaryStatistics()); ! instances.add(countTo(1000).parallelStream().collect(Collectors.toDoubleSummaryStatistics(i -> i))); instances.add(countTo(1000).parallelStream().mapToDouble(i -> i).summaryStatistics()); for (DoubleSummaryStatistics stats : instances) { assertEquals(stats.getCount(), 1000); assertEquals(stats.getSum(), (double) countTo(1000).stream().mapToInt(i -> i).sum()); --- 71,83 ---- } } public void testDoubleStatistics() { List<DoubleSummaryStatistics> instances = new ArrayList<>(); ! instances.add(countTo(1000).stream().collect(Collectors.summarizingDouble(i -> i))); instances.add(countTo(1000).stream().mapToDouble(i -> i).summaryStatistics()); ! instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingDouble(i -> i))); instances.add(countTo(1000).parallelStream().mapToDouble(i -> i).summaryStatistics()); for (DoubleSummaryStatistics stats : instances) { assertEquals(stats.getCount(), 1000); assertEquals(stats.getSum(), (double) countTo(1000).stream().mapToInt(i -> i).sum());