/libcore/ojluni/src/main/java/java/util/stream/ |
H A D | BaseStream.java | 91 boolean isParallel(); method in interface:BaseStream
|
H A D | AbstractPipeline.java | 233 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 D | DoublePipeline.java | 146 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 D | IntPipeline.java | 149 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 D | LongPipeline.java | 147 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 D | ReferencePipeline.java | 116 boolean isParallel) { 117 return new StreamSpliterators.WrappingSpliterator<>(ph, supplier, isParallel); 493 if (isParallel() 582 if (!isParallel()) { 592 if (!isParallel()) { 114 wrap(PipelineHelper<P_OUT> ph, Supplier<Spliterator<P_IN>> supplier, boolean isParallel) argument
|
H A D | StreamSpliterators.java | 70 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 D | DoubleStreamTestScenario.java | 50 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 D | IntStreamTestScenario.java | 50 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 D | LongStreamTestScenario.java | 50 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 D | StreamTestScenario.java | 49 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 D | OpTestCase.java | 83 * @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 D | DoubleStreamTestScenario.java | 54 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 D | IntStreamTestScenario.java | 53 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 D | LongStreamTestScenario.java | 53 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 D | StreamTestScenario.java | 52 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 D | OpTestCase.java | 84 * @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;
|