/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
H A D | ConcatTest.java | 111 Stream<Integer> s1p = c1.parallelStream(); 112 Stream<Integer> s2p = c2.parallelStream(); 179 assertRefConcat(c1.parallelStream(), c2.parallelStream(), true, true); 181 assertRefConcat(c1.stream(), c2.parallelStream(), true, true); 183 assertRefConcat(c1.parallelStream(), c2.stream(), true, true); 188 assertRefConcat(c1.parallelStream().unordered(), c2.stream().unordered(), true, false); 195 assertIntConcat(c1.parallelStream(), c2.parallelStream(), true, true); 197 assertIntConcat(c1.stream(), c2.parallelStream(), tru [all...] |
H A D | SummaryStatisticsTest.java | 49 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingInt(i -> i))); 50 instances.add(countTo(1000).parallelStream().mapToInt(i -> i).summaryStatistics()); 64 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingLong(i -> i))); 65 instances.add(countTo(1000).parallelStream().mapToLong(i -> i).summaryStatistics()); 79 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingDouble(i -> i))); 80 instances.add(countTo(1000).parallelStream().mapToDouble(i -> i).summaryStatistics());
|
H A D | SliceOpTest.java | 60 assertCountSum(countTo(0).parallelStream().skip(0), 0, 0); 61 assertCountSum(countTo(0).parallelStream().skip(4), 0, 0); 62 assertCountSum(countTo(4).parallelStream().skip(4), 0, 0); 63 assertCountSum(countTo(4).parallelStream().skip(2), 2, 7); 64 assertCountSum(countTo(4).parallelStream().skip(0), 4, 10); 83 assertCountSum(countTo(0).parallelStream().limit(4), 0, 0); 84 assertCountSum(countTo(2).parallelStream().limit(4), 2, 3); 85 assertCountSum(countTo(4).parallelStream().limit(4), 4, 10); 86 assertCountSum(countTo(8).parallelStream().limit(4), 4, 10);
|
H A D | FindAnyOpTest.java | 61 assertFalse(Collections.emptySet().parallelStream().findAny().isPresent(), "no result"); 62 assertFalse(countTo(1000).parallelStream().filter(x -> x > 1000).findAny().isPresent(), "no result"); 63 assertTrue(countTo(1000).parallelStream().filter(pEven).findAny().isPresent(), "with result");
|
H A D | SequentialOpTest.java | 56 Supplier<Stream<Integer>>[] suppliers = new Supplier[] { () -> data.stream(), () -> data.parallelStream() };
|
H A D | StreamSpliteratorTest.java | 317 SpliteratorTestHelper.testSpliterator(() -> f.apply(data.parallelStream()).spliterator()); 413 SpliteratorTestHelper.testIntSpliterator(() -> f.apply(data.parallelStream()).spliterator()); 506 SpliteratorTestHelper.testLongSpliterator(() -> f.apply(data.parallelStream()).spliterator()); 599 SpliteratorTestHelper.testDoubleSpliterator(() -> f.apply(data.parallelStream()).spliterator());
|
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
H A D | DoubleStreamTestScenario.java | 103 m.apply(data.parallelStream()).sequential().forEach(b); 112 m.apply(data.parallelStream()).forEachOrdered(b); 120 for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { 129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 136 for (double t : m.apply(data.parallelStream()).toArray()) 145 DoubleStream s = m.apply(data.parallelStream()); 158 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 171 m.apply(data.parallelStream()).forEach(e -> { 183 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
|
H A D | IntStreamTestScenario.java | 103 m.apply(data.parallelStream()).sequential().forEach(b); 112 m.apply(data.parallelStream()).forEachOrdered(b); 120 for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { 129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 136 for (int t : m.apply(data.parallelStream()).toArray()) 145 IntStream s = m.apply(data.parallelStream()); 159 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 172 m.apply(data.parallelStream()).forEach(e -> { 184 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
|
H A D | LongStreamTestScenario.java | 103 m.apply(data.parallelStream()).sequential().forEach(b); 112 m.apply(data.parallelStream()).forEachOrdered(b); 120 for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { 129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 136 for (long t : m.apply(data.parallelStream()).toArray()) 145 LongStream s = m.apply(data.parallelStream()); 158 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 171 m.apply(data.parallelStream()).forEach(e -> { 183 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
|
H A D | StreamTestScenario.java | 114 m.apply(data.parallelStream()).sequential().forEach(b); 123 m.apply(data.parallelStream()).forEachOrdered(b); 131 for (Spliterator<U> spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { } 139 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 147 for (Object t : m.apply(data.parallelStream()).toArray()) 156 Stream<U> s = m.apply(data.parallelStream()); 170 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 183 for (U u : m.apply(data.parallelStream()).collect(Collectors.toList())) 201 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) 210 m.apply(data.parallelStream()) [all...] |
H A D | TestData.java | 66 S parallelStream(); method in interface:TestData 84 return new AbstractTestData.RefTestData<>(name, collection, Collection::stream, Collection::parallelStream, 261 public S parallelStream() { method in class:TestData.AbstractTestData
|
H A D | OpTestCase.java | 571 ? data.parallelStream() : data.stream());
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
H A D | DoubleStreamTestScenario.java | 107 m.apply(data.parallelStream()).sequential().forEach(b); 116 m.apply(data.parallelStream()).forEachOrdered(b); 124 for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { 133 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 140 for (double t : m.apply(data.parallelStream()).toArray()) 149 DoubleStream s = m.apply(data.parallelStream()); 162 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 175 m.apply(data.parallelStream()).forEach(e -> { 187 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
|
H A D | IntStreamTestScenario.java | 106 m.apply(data.parallelStream()).sequential().forEach(b); 115 m.apply(data.parallelStream()).forEachOrdered(b); 123 for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { 132 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 139 for (int t : m.apply(data.parallelStream()).toArray()) 148 IntStream s = m.apply(data.parallelStream()); 162 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 175 m.apply(data.parallelStream()).forEach(e -> { 187 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
|
H A D | LongStreamTestScenario.java | 106 m.apply(data.parallelStream()).sequential().forEach(b); 115 m.apply(data.parallelStream()).forEachOrdered(b); 123 for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { 132 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 139 for (long t : m.apply(data.parallelStream()).toArray()) 148 LongStream s = m.apply(data.parallelStream()); 161 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 174 m.apply(data.parallelStream()).forEach(e -> { 186 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(),
|
H A D | StreamTestScenario.java | 117 m.apply(data.parallelStream()).sequential().forEach(b); 126 m.apply(data.parallelStream()).forEachOrdered(b); 134 for (Spliterator<U> spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { } 142 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); 150 for (Object t : m.apply(data.parallelStream()).toArray()) 159 Stream<U> s = m.apply(data.parallelStream()); 173 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), 186 for (U u : m.apply(data.parallelStream()).collect(Collectors.toList())) 204 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) 213 m.apply(data.parallelStream()) [all...] |
H A D | TestData.java | 67 S parallelStream(); method in interface:TestData 85 return new AbstractTestData.RefTestData<>(name, collection, Collection::stream, Collection::parallelStream, 262 public S parallelStream() { method in class:TestData.AbstractTestData
|
H A D | OpTestCase.java | 572 ? data.parallelStream() : data.stream());
|
/libcore/ojluni/src/main/java/java/util/ |
H A D | Collection.java | 508 * {@link #parallelStream()}} methods, spliterators should either have the 513 * and should override the {@link #stream()} and {@link #parallelStream()} 520 * {@link #stream()} and {@link #parallelStream()} methods will reflect the 588 default Stream<E> parallelStream() { method in interface:Collection
|
H A D | Collections.java | 1173 public Stream<E> parallelStream() { method in class:Collections.UnmodifiableCollection 1174 return (Stream<E>)c.parallelStream(); 1634 public Stream<Entry<K,V>> parallelStream() { method in class:Collections.UnmodifiableMap.UnmodifiableEntrySet 1922 public Stream<E> parallelStream() { method in class:Collections.SynchronizedCollection 1923 return c.parallelStream(); // Must be manually synched by user! 2706 public Stream<E> parallelStream() {return c.parallelStream();} method in class:Collections.CheckedCollection 4269 public Stream<E> parallelStream() { method in class:Collections.CopiesList 4687 public Stream<E> parallelStream() {return s.parallelStream();} method in class:Collections.SetFromMap 4762 public Stream<E> parallelStream() {return q.parallelStream();} method in class:Collections.AsLIFOQueue [all...] |
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
H A D | StreamReuseTest.java | 63 stream = data.parallelStream();
|