Searched refs:parallelStream (Results 1 - 21 of 21) sorted by relevance

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DConcatTest.java111 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 DSummaryStatisticsTest.java49 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 DSliceOpTest.java60 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 DFindAnyOpTest.java61 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 DSequentialOpTest.java56 Supplier<Stream<Integer>>[] suppliers = new Supplier[] { () -> data.stream(), () -> data.parallelStream() };
H A DStreamSpliteratorTest.java317 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 DDoubleStreamTestScenario.java103 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 DIntStreamTestScenario.java103 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 DLongStreamTestScenario.java103 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 DStreamTestScenario.java114 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 DTestData.java66 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 DOpTestCase.java571 ? data.parallelStream() : data.stream());
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
H A DDoubleStreamTestScenario.java107 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 DIntStreamTestScenario.java106 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 DLongStreamTestScenario.java106 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 DStreamTestScenario.java117 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 DTestData.java67 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 DOpTestCase.java572 ? data.parallelStream() : data.stream());
/libcore/ojluni/src/main/java/java/util/
H A DCollection.java508 * {@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 DCollections.java1173 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 DStreamReuseTest.java63 stream = data.parallelStream();

Completed in 274 milliseconds