HomeSort by relevance Sort by last modified time
    Searched refs:parallelStream (Results 1 - 22 of 22) sorted by null

  /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
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(), true, true)
    [all...]
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());
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);
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");
SequentialOpTest.java 56 Supplier<Stream<Integer>>[] suppliers = new Supplier[] { () -> data.stream(), () -> data.parallelStream() };
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/
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(),
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(),
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(),
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()).forEach(e ->
    [all...]
TestData.java 66 S parallelStream();
84 return new AbstractTestData.RefTestData<>(name, collection, Collection::stream, Collection::parallelStream,
261 public S parallelStream() {
OpTestCase.java 571 ? data.parallelStream() : data.stream());
  /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
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(),
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(),
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(),
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()).forEach(e ->
    [all...]
TestData.java 67 S parallelStream();
85 return new AbstractTestData.RefTestData<>(name, collection, Collection::stream, Collection::parallelStream,
262 public S parallelStream() {
OpTestCase.java 572 ? data.parallelStream() : data.stream());
  /libcore/ojluni/src/main/java/java/util/
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() {
Collections.java     [all...]
  /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
StreamReuseTest.java 63 stream = data.parallelStream();
  /prebuilts/sdk/24/
android.jar 

Completed in 478 milliseconds