Home
last modified time | relevance | path

Searched refs:isParallel (Results 1 – 25 of 28) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DStreamParSeqTest.java38 assertTrue(s.isParallel()); in testParSeq()
41 assertFalse(s.isParallel()); in testParSeq()
44 assertFalse(s.isParallel()); in testParSeq()
47 assertTrue(s.isParallel()); in testParSeq()
50 assertTrue(s.isParallel()); in testParSeq()
DConcatTest.java113 assertTrue(s1p.isParallel()); in checkPrerequisites()
114 assertTrue(s2p.isParallel()); in checkPrerequisites()
115 assertFalse(s1s.isParallel()); in checkPrerequisites()
116 assertFalse(s2s.isParallel()); in checkPrerequisites()
147 assertEquals(result.isParallel(), parallel); in assertRefConcat()
154 assertEquals(result.isParallel(), parallel); in assertIntConcat()
162 assertEquals(result.isParallel(), parallel); in assertLongConcat()
170 assertEquals(result.isParallel(), parallel); in assertDoubleConcat()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatelessTestOp.java38 return op.opWrapSink(flags, isParallel(), sink); in chain()
44 return op.opWrapSink(flags, isParallel(), sink); in chain()
51 return op.opWrapSink(flags, isParallel(), sink); in chain()
58 return op.opWrapSink(flags, isParallel(), sink); in chain()
DIntStreamTestScenario.java50 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
199 private final boolean isParallel; field in IntStreamTestScenario
203 IntStreamTestScenario(boolean isParallel) { in IntStreamTestScenario() argument
204 this(isParallel, true); in IntStreamTestScenario()
207 IntStreamTestScenario(boolean isParallel, boolean isOrdered) { in IntStreamTestScenario() argument
208 this.isParallel = isParallel; in IntStreamTestScenario()
216 public boolean isParallel() { in isParallel() method in IntStreamTestScenario
217 return isParallel; in isParallel()
DDoubleStreamTestScenario.java50 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
198 private boolean isParallel; field in DoubleStreamTestScenario
202 DoubleStreamTestScenario(boolean isParallel) { in DoubleStreamTestScenario() argument
203 this(isParallel, true); in DoubleStreamTestScenario()
206 DoubleStreamTestScenario(boolean isParallel, boolean isOrdered) { in DoubleStreamTestScenario() argument
207 this.isParallel = isParallel; in DoubleStreamTestScenario()
215 public boolean isParallel() { in isParallel() method in DoubleStreamTestScenario
216 return isParallel; in isParallel()
DLongStreamTestScenario.java50 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
198 private boolean isParallel; field in LongStreamTestScenario
202 LongStreamTestScenario(boolean isParallel) { in LongStreamTestScenario() argument
203 this(isParallel, true); in LongStreamTestScenario()
206 LongStreamTestScenario(boolean isParallel, boolean isOrdered) { in LongStreamTestScenario() argument
207 this.isParallel = isParallel; in LongStreamTestScenario()
215 public boolean isParallel() { in isParallel() method in LongStreamTestScenario
216 return isParallel; in isParallel()
DStreamTestScenario.java49 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
237 private final boolean isParallel; field in StreamTestScenario
241 StreamTestScenario(boolean isParallel) { in StreamTestScenario() argument
242 this(isParallel, true); in StreamTestScenario()
245 StreamTestScenario(boolean isParallel, boolean isOrdered) { in StreamTestScenario() argument
246 this.isParallel = isParallel; in StreamTestScenario()
254 public boolean isParallel() { in isParallel() method in StreamTestScenario
255 return isParallel; in isParallel()
DStatefulTestOp.java41 return op.opWrapSink(flags, isParallel(), sink); in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
81 return op.opWrapSink(flags, isParallel(), sink); in chain()
101 return op.opWrapSink(flags, isParallel(), sink); in chain()
DOpTestCase.java85 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); in assertResult() argument
93 boolean isParallel(); in isParallel() method
397 …ltAsserter.assertResult(result, refResult, isStreamOrdered && test.isOrdered(), test.isParallel()); in exercise()
489 private final boolean isParallel; field in OpTestCase.TerminalTestScenario
491 TerminalTestScenario(boolean requiresSingleStageSource, boolean isParallel) { in TerminalTestScenario() argument
493 this.isParallel = isParallel; in TerminalTestScenario()
503 return isParallel; in requiresParallelSource()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatelessTestOp.java47 return op.opWrapSink(flags, isParallel(), sink); in chain()
54 return op.opWrapSink(flags, isParallel(), sink); in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
68 return op.opWrapSink(flags, isParallel(), sink); in chain()
DIntStreamTestScenario.java53 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
202 private final boolean isParallel; field in IntStreamTestScenario
206 IntStreamTestScenario(boolean isParallel) { in IntStreamTestScenario() argument
207 this(isParallel, true); in IntStreamTestScenario()
210 IntStreamTestScenario(boolean isParallel, boolean isOrdered) { in IntStreamTestScenario() argument
211 this.isParallel = isParallel; in IntStreamTestScenario()
219 public boolean isParallel() { in isParallel() method in IntStreamTestScenario
220 return isParallel; in isParallel()
DDoubleStreamTestScenario.java54 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
202 private boolean isParallel; field in DoubleStreamTestScenario
206 DoubleStreamTestScenario(boolean isParallel) { in DoubleStreamTestScenario() argument
207 this(isParallel, true); in DoubleStreamTestScenario()
210 DoubleStreamTestScenario(boolean isParallel, boolean isOrdered) { in DoubleStreamTestScenario() argument
211 this.isParallel = isParallel; in DoubleStreamTestScenario()
219 public boolean isParallel() { in isParallel() method in DoubleStreamTestScenario
220 return isParallel; in isParallel()
DLongStreamTestScenario.java53 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
201 private boolean isParallel; field in LongStreamTestScenario
205 LongStreamTestScenario(boolean isParallel) { in LongStreamTestScenario() argument
206 this(isParallel, true); in LongStreamTestScenario()
209 LongStreamTestScenario(boolean isParallel, boolean isOrdered) { in LongStreamTestScenario() argument
210 this.isParallel = isParallel; in LongStreamTestScenario()
218 public boolean isParallel() { in isParallel() method in LongStreamTestScenario
219 return isParallel; in isParallel()
DStreamTestScenario.java52 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
240 private final boolean isParallel; field in StreamTestScenario
244 StreamTestScenario(boolean isParallel) { in StreamTestScenario() argument
245 this(isParallel, true); in StreamTestScenario()
248 StreamTestScenario(boolean isParallel, boolean isOrdered) { in StreamTestScenario() argument
249 this.isParallel = isParallel; in StreamTestScenario()
257 public boolean isParallel() { in isParallel() method in StreamTestScenario
258 return isParallel; in isParallel()
DStatefulTestOp.java42 return op.opWrapSink(flags, isParallel(), sink); in chain()
62 return op.opWrapSink(flags, isParallel(), sink); in chain()
82 return op.opWrapSink(flags, isParallel(), sink); in chain()
102 return op.opWrapSink(flags, isParallel(), sink); in chain()
DOpTestCase.java86 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); in assertResult() argument
94 boolean isParallel(); in isParallel() method
398 …ltAsserter.assertResult(result, refResult, isStreamOrdered && test.isOrdered(), test.isParallel()); in exercise()
490 private final boolean isParallel; field in OpTestCase.TerminalTestScenario
492 TerminalTestScenario(boolean requiresSingleStageSource, boolean isParallel) { in TerminalTestScenario() argument
494 this.isParallel = isParallel; in TerminalTestScenario()
504 return isParallel; in requiresParallelSource()
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractPipeline.java234 return isParallel() in evaluate()
254 if (isParallel() && previousStage != null && opIsStateful()) { in evaluateToArrayNode()
367 return wrap(this, () -> sourceSpliterator(0), isParallel()); in spliterator()
372 public final boolean isParallel() { in isParallel() method in AbstractPipeline
413 if (isParallel() && sourceStage.sourceAnyStateful) { in sourceSpliterator()
535 return wrap(this, () -> sourceSpliterator, isParallel()); in wrapSpliterator()
545 if (isParallel()) { in evaluate()
598 boolean isParallel); in wrap() argument
DBaseStream.java93 boolean isParallel(); in isParallel() method
DDoubleStream.java834 DoubleStream stream = StreamSupport.doubleStream(split, a.isParallel() || b.isParallel()); in concat()
DReferencePipeline.java120 boolean isParallel) { in wrap() argument
121 return new StreamSpliterators.WrappingSpliterator<>(ph, supplier, isParallel); in wrap()
509 if (isParallel()
603 if (!isParallel()) {
613 if (!isParallel()) {
DIntStream.java852 IntStream stream = StreamSupport.intStream(split, a.isParallel() || b.isParallel()); in concat()
DIntPipeline.java153 boolean isParallel) { in wrap() argument
154 return new StreamSpliterators.IntWrappingSpliterator<>(ph, supplier, isParallel); in wrap()
579 if (!isParallel()) {
589 if (!isParallel()) {
DDoublePipeline.java150 boolean isParallel) { in wrap() argument
151 return new StreamSpliterators.DoubleWrappingSpliterator<>(ph, supplier, isParallel); in wrap()
581 if (!isParallel()) {
591 if (!isParallel()) {
DLongPipeline.java151 boolean isParallel) { in wrap() argument
152 return new StreamSpliterators.LongWrappingSpliterator<>(ph, supplier, isParallel); in wrap()
562 if (!isParallel()) {
571 if (!isParallel()) {
DLongStream.java860 LongStream stream = StreamSupport.longStream(split, a.isParallel() || b.isParallel()); in concat()

12