Searched defs:isParallel (Results 1 - 17 of 17) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
H A DBaseStream.java91 boolean isParallel(); method in interface:BaseStream
H A DAbstractPipeline.java233 return isParallel()
252 if (isParallel() && previousStage != null && opIsStateful()) {
365 return wrap(this, () -> sourceSpliterator(0), isParallel());
370 public final boolean isParallel() { method in class:AbstractPipeline
410 if (isParallel() && sourceStage.sourceAnyStateful) {
530 return wrap(this, () -> sourceSpliterator, isParallel());
539 if (isParallel()) {
589 boolean isParallel);
587 wrap(PipelineHelper<E_OUT> ph, Supplier<Spliterator<P_IN>> supplier, boolean isParallel) argument
H A DDoublePipeline.java146 boolean isParallel) {
147 return new StreamSpliterators.DoubleWrappingSpliterator<>(ph, supplier, isParallel);
561 if (!isParallel()) {
571 if (!isParallel()) {
144 wrap(PipelineHelper<Double> ph, Supplier<Spliterator<P_IN>> supplier, boolean isParallel) argument
H A DIntPipeline.java149 boolean isParallel) {
150 return new StreamSpliterators.IntWrappingSpliterator<>(ph, supplier, isParallel);
558 if (!isParallel()) {
568 if (!isParallel()) {
147 wrap(PipelineHelper<Integer> ph, Supplier<Spliterator<P_IN>> supplier, boolean isParallel) argument
H A DLongPipeline.java147 boolean isParallel) {
148 return new StreamSpliterators.LongWrappingSpliterator<>(ph, supplier, isParallel);
541 if (!isParallel()) {
550 if (!isParallel()) {
145 wrap(PipelineHelper<Long> ph, Supplier<Spliterator<P_IN>> supplier, boolean isParallel) argument
H A DReferencePipeline.java116 boolean isParallel) {
117 return new StreamSpliterators.WrappingSpliterator<>(ph, supplier, isParallel);
492 if (isParallel()
581 if (!isParallel()) {
591 if (!isParallel()) {
114 wrap(PipelineHelper<P_OUT> ph, Supplier<Spliterator<P_IN>> supplier, boolean isParallel) argument
H A DStreamSpliterators.java70 final boolean isParallel; field in class:StreamSpliterators.AbstractWrappingSpliterator
121 this.isParallel = parallel;
134 this.isParallel = parallel;
189 if (isParallel && !finished) {
286 return new WrappingSpliterator<>(ph, s, isParallel);
339 return new IntWrappingSpliterator<>(ph, s, isParallel);
397 return new LongWrappingSpliterator<>(ph, s, isParallel);
455 return new DoubleWrappingSpliterator<>(ph, s, isParallel);
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
H A DDoubleStreamTestScenario.java50 if (s.isParallel()) {
198 private boolean isParallel; field in class:DoubleStreamTestScenario
202 DoubleStreamTestScenario(boolean isParallel) { argument
203 this(isParallel, true);
206 DoubleStreamTestScenario(boolean isParallel, boolean isOrdered) { argument
207 this.isParallel = isParallel;
215 public boolean isParallel() { method in class:DoubleStreamTestScenario
216 return isParallel;
H A DIntStreamTestScenario.java50 if (s.isParallel()) {
199 private final boolean isParallel; field in class:IntStreamTestScenario
203 IntStreamTestScenario(boolean isParallel) { argument
204 this(isParallel, true);
207 IntStreamTestScenario(boolean isParallel, boolean isOrdered) { argument
208 this.isParallel = isParallel;
216 public boolean isParallel() { method in class:IntStreamTestScenario
217 return isParallel;
H A DLongStreamTestScenario.java50 if (s.isParallel()) {
198 private boolean isParallel; field in class:LongStreamTestScenario
202 LongStreamTestScenario(boolean isParallel) { argument
203 this(isParallel, true);
206 LongStreamTestScenario(boolean isParallel, boolean isOrdered) { argument
207 this.isParallel = isParallel;
215 public boolean isParallel() { method in class:LongStreamTestScenario
216 return isParallel;
H A DStreamTestScenario.java49 if (s.isParallel()) {
237 private final boolean isParallel; field in class:StreamTestScenario
241 StreamTestScenario(boolean isParallel) { argument
242 this(isParallel, true);
245 StreamTestScenario(boolean isParallel, boolean isOrdered) { argument
246 this.isParallel = isParallel;
254 public boolean isParallel() { method in class:StreamTestScenario
255 return isParallel;
H A DOpTestCase.java83 * @param isParallel true if the pipeline is parallel
85 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); argument
93 boolean isParallel(); method in interface:OpTestCase.BaseStreamTestScenario
397 Runnable asserter = () -> resultAsserter.assertResult(result, refResult, isStreamOrdered && test.isOrdered(), test.isParallel());
489 private final boolean isParallel; field in class:OpTestCase.TerminalTestScenario
491 TerminalTestScenario(boolean requiresSingleStageSource, boolean isParallel) { argument
493 this.isParallel = isParallel;
503 return isParallel;
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
H A DDoubleStreamTestScenario.java54 if (s.isParallel()) {
202 private boolean isParallel; field in class:DoubleStreamTestScenario
206 DoubleStreamTestScenario(boolean isParallel) { argument
207 this(isParallel, true);
210 DoubleStreamTestScenario(boolean isParallel, boolean isOrdered) { argument
211 this.isParallel = isParallel;
219 public boolean isParallel() { method in class:DoubleStreamTestScenario
220 return isParallel;
H A DIntStreamTestScenario.java53 if (s.isParallel()) {
202 private final boolean isParallel; field in class:IntStreamTestScenario
206 IntStreamTestScenario(boolean isParallel) { argument
207 this(isParallel, true);
210 IntStreamTestScenario(boolean isParallel, boolean isOrdered) { argument
211 this.isParallel = isParallel;
219 public boolean isParallel() { method in class:IntStreamTestScenario
220 return isParallel;
H A DLongStreamTestScenario.java53 if (s.isParallel()) {
201 private boolean isParallel; field in class:LongStreamTestScenario
205 LongStreamTestScenario(boolean isParallel) { argument
206 this(isParallel, true);
209 LongStreamTestScenario(boolean isParallel, boolean isOrdered) { argument
210 this.isParallel = isParallel;
218 public boolean isParallel() { method in class:LongStreamTestScenario
219 return isParallel;
H A DStreamTestScenario.java52 if (s.isParallel()) {
240 private final boolean isParallel; field in class:StreamTestScenario
244 StreamTestScenario(boolean isParallel) { argument
245 this(isParallel, true);
248 StreamTestScenario(boolean isParallel, boolean isOrdered) { argument
249 this.isParallel = isParallel;
257 public boolean isParallel() { method in class:StreamTestScenario
258 return isParallel;
H A DOpTestCase.java84 * @param isParallel true if the pipeline is parallel
86 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); argument
94 boolean isParallel(); method in interface:OpTestCase.BaseStreamTestScenario
398 Runnable asserter = () -> resultAsserter.assertResult(result, refResult, isStreamOrdered && test.isOrdered(), test.isParallel());
490 private final boolean isParallel; field in class:OpTestCase.TerminalTestScenario
492 TerminalTestScenario(boolean requiresSingleStageSource, boolean isParallel) { argument
494 this.isParallel = isParallel;
504 return isParallel;

Completed in 269 milliseconds