/libcore/ojluni/src/main/java/java/util/stream/ |
H A D | BaseStream.java | 37 * sequential and parallel aggregate operations. The following example 86 * would execute in parallel. Calling this method after invoking an 89 * @return {@code true} if this stream would execute in parallel if executed 106 * Returns an equivalent stream that is parallel. May return 107 * itself, either because the stream was already parallel, or because 108 * the underlying stream state was modified to be parallel. 113 * @return a parallel stream 115 S parallel(); method in interface:BaseStream
|
H A D | StreamSupport.java | 46 * Creates a new sequential or parallel {@code Stream} from a 62 * @param parallel if {@code true} then the returned stream is a parallel 65 * @return a new sequential or parallel {@code Stream} 67 public static <T> Stream<T> stream(Spliterator<T> spliterator, boolean parallel) { argument 71 parallel); 75 * Creates a new sequential or parallel {@code Stream} from a 101 * @param parallel if {@code true} then the returned stream is a parallel 104 * @return a new sequential or parallel { 107 stream(Supplier<? extends Spliterator<T>> supplier, int characteristics, boolean parallel) argument 137 intStream(Spliterator.OfInt spliterator, boolean parallel) argument 175 intStream(Supplier<? extends Spliterator.OfInt> supplier, int characteristics, boolean parallel) argument 204 longStream(Spliterator.OfLong spliterator, boolean parallel) argument 243 longStream(Supplier<? extends Spliterator.OfLong> supplier, int characteristics, boolean parallel) argument 272 doubleStream(Spliterator.OfDouble spliterator, boolean parallel) argument 311 doubleStream(Supplier<? extends Spliterator.OfDouble> supplier, int characteristics, boolean parallel) argument [all...] |
H A D | AbstractPipeline.java | 57 * <p>For sequential streams, and parallel streams without 59 * operations</a>, parallel streams, pipeline evaluation is done in a single 60 * pass that "jams" all the operations together. For parallel streams with 106 * and the stream source if sequential, or the previous stateful if parallel. 147 * True if pipeline is parallel, otherwise the pipeline is sequential; only 150 private boolean parallel; field in class:AbstractPipeline 158 * @param parallel True if the pipeline is parallel 161 int sourceFlags, boolean parallel) { 170 this.parallel 160 AbstractPipeline(Supplier<? extends Spliterator<?>> source, int sourceFlags, boolean parallel) argument 181 AbstractPipeline(Spliterator<?> source, int sourceFlags, boolean parallel) argument 311 public final S parallel() { method in class:AbstractPipeline [all...] |
H A D | DoubleStream.java | 51 * A sequence of primitive double-valued elements supporting sequential and parallel 201 * <p>For parallel stream pipelines, the action may be called at 233 * stream pipelines, it can be quite expensive on ordered parallel pipelines, 239 * speedups of {@code limit()} in parallel pipelines, if the semantics of 242 * {@code limit()} in parallel pipelines, switching to sequential execution 262 * stream pipelines, it can be quite expensive on ordered parallel pipelines, 268 * speedups of {@code skip()} in parallel pipelines, if the semantics of 271 * {@code skip()} in parallel pipelines, switching to sequential execution 286 * <p>For parallel stream pipelines, this operation does <em>not</em> 437 * parallel executio 708 DoubleStream parallel(); method in interface:DoubleStream [all...] |
H A D | DoublePipeline.java | 67 int sourceFlags, boolean parallel) { 68 super(source, sourceFlags, parallel); 79 int sourceFlags, boolean parallel) { 80 super(source, sourceFlags, parallel); 527 * @param parallel {@code true} if the pipeline is parallel 530 int sourceFlags, boolean parallel) { 531 super(source, sourceFlags, parallel); 540 * @param parallel {@code true} if the pipeline is parallel 66 DoublePipeline(Supplier<? extends Spliterator<Double>> source, int sourceFlags, boolean parallel) argument 78 DoublePipeline(Spliterator<Double> source, int sourceFlags, boolean parallel) argument 529 Head(Supplier<? extends Spliterator<Double>> source, int sourceFlags, boolean parallel) argument 542 Head(Spliterator<Double> source, int sourceFlags, boolean parallel) argument [all...] |
H A D | IntPipeline.java | 64 * @param parallel {@code true} if the pipeline is parallel 67 int sourceFlags, boolean parallel) { 68 super(source, sourceFlags, parallel); 77 * @param parallel {@code true} if the pipeline is parallel 80 int sourceFlags, boolean parallel) { 81 super(source, sourceFlags, parallel); 524 * @param parallel {@code true} if the pipeline is parallel 66 IntPipeline(Supplier<? extends Spliterator<Integer>> source, int sourceFlags, boolean parallel) argument 79 IntPipeline(Spliterator<Integer> source, int sourceFlags, boolean parallel) argument 526 Head(Supplier<? extends Spliterator<Integer>> source, int sourceFlags, boolean parallel) argument 539 Head(Spliterator<Integer> source, int sourceFlags, boolean parallel) argument [all...] |
H A D | IntStream.java | 49 * A sequence of primitive int-valued elements supporting sequential and parallel 196 * <p>For parallel stream pipelines, the action may be called at 228 * stream pipelines, it can be quite expensive on ordered parallel pipelines, 234 * speedups of {@code limit()} in parallel pipelines, if the semantics of 237 * {@code limit()} in parallel pipelines, switching to sequential execution 257 * stream pipelines, it can be quite expensive on ordered parallel pipelines, 263 * speedups of {@code skip()} in parallel pipelines, if the semantics of 266 * {@code skip()} in parallel pipelines, switching to sequential execution 281 * <p>For parallel stream pipelines, this operation does <em>not</em> 431 * parallel executio 677 IntStream parallel(); method in interface:IntStream [all...] |
H A D | LongPipeline.java | 65 * @param parallel {@code true} if the pipeline is parallel 68 int sourceFlags, boolean parallel) { 69 super(source, sourceFlags, parallel); 78 * @param parallel {@code true} if the pipeline is parallel 81 int sourceFlags, boolean parallel) { 82 super(source, sourceFlags, parallel); 507 * @param parallel {@code true} if the pipeline is parallel 67 LongPipeline(Supplier<? extends Spliterator<Long>> source, int sourceFlags, boolean parallel) argument 80 LongPipeline(Spliterator<Long> source, int sourceFlags, boolean parallel) argument 509 Head(Supplier<? extends Spliterator<Long>> source, int sourceFlags, boolean parallel) argument 522 Head(Spliterator<Long> source, int sourceFlags, boolean parallel) argument [all...] |
H A D | LongStream.java | 53 * A sequence of primitive long-valued elements supporting sequential and parallel 200 * <p>For parallel stream pipelines, the action may be called at 232 * stream pipelines, it can be quite expensive on ordered parallel pipelines, 238 * speedups of {@code limit()} in parallel pipelines, if the semantics of 241 * {@code limit()} in parallel pipelines, switching to sequential execution 261 * stream pipelines, it can be quite expensive on ordered parallel pipelines, 267 * speedups of {@code skip()} in parallel pipelines, if the semantics of 270 * {@code skip()} in parallel pipelines, switching to sequential execution 285 * <p>For parallel stream pipelines, this operation does <em>not</em> 435 * parallel executio 669 LongStream parallel(); method in interface:LongStream [all...] |
H A D | ReferencePipeline.java | 68 * @param parallel {@code true} if the pipeline is parallel 71 int sourceFlags, boolean parallel) { 72 super(source, sourceFlags, parallel); 81 * @param parallel {@code true} if the pipeline is parallel 84 int sourceFlags, boolean parallel) { 85 super(source, sourceFlags, parallel); 552 int sourceFlags, boolean parallel) { 553 super(source, sourceFlags, parallel); 70 ReferencePipeline(Supplier<? extends Spliterator<?>> source, int sourceFlags, boolean parallel) argument 83 ReferencePipeline(Spliterator<?> source, int sourceFlags, boolean parallel) argument 551 Head(Supplier<? extends Spliterator<?>> source, int sourceFlags, boolean parallel) argument 563 Head(Spliterator<?> source, int sourceFlags, boolean parallel) argument [all...] |
H A D | StreamSpliterators.java | 117 boolean parallel) { 121 this.isParallel = parallel; 130 boolean parallel) { 134 this.isParallel = parallel; 274 boolean parallel) { 275 super(ph, supplier, parallel); 280 boolean parallel) { 281 super(ph, spliterator, parallel); 327 boolean parallel) { 328 super(ph, supplier, parallel); 115 AbstractWrappingSpliterator(PipelineHelper<P_OUT> ph, Supplier<Spliterator<P_IN>> spliteratorSupplier, boolean parallel) argument 128 AbstractWrappingSpliterator(PipelineHelper<P_OUT> ph, Spliterator<P_IN> spliterator, boolean parallel) argument 272 WrappingSpliterator(PipelineHelper<P_OUT> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument 278 WrappingSpliterator(PipelineHelper<P_OUT> ph, Spliterator<P_IN> spliterator, boolean parallel) argument 325 IntWrappingSpliterator(PipelineHelper<Integer> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument 331 IntWrappingSpliterator(PipelineHelper<Integer> ph, Spliterator<P_IN> spliterator, boolean parallel) argument 383 LongWrappingSpliterator(PipelineHelper<Long> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument 389 LongWrappingSpliterator(PipelineHelper<Long> ph, Spliterator<P_IN> spliterator, boolean parallel) argument 441 DoubleWrappingSpliterator(PipelineHelper<Double> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument 447 DoubleWrappingSpliterator(PipelineHelper<Double> ph, Spliterator<P_IN> spliterator, boolean parallel) argument [all...] |
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
H A D | FlagDeclaringOp.java | 58 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { argument
|
H A D | StatelessTestOp.java | 71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink); argument
|
H A D | StatefulTestOp.java | 127 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink); argument
|
H A D | TestFlagExpectedOp.java | 104 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
|
H A D | CollectorOps.java | 64 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { argument
|
H A D | OpTestCase.java | 83 * @param isParallel true if the pipeline is parallel 584 AbstractPipeline createPipeline(StreamShape shape, Spliterator s, int flags, boolean parallel) { argument 586 case REFERENCE: return new ReferencePipeline.Head<>(s, flags, parallel); 587 case INT_VALUE: return new IntPipeline.Head(s, flags, parallel); 588 case LONG_VALUE: return new LongPipeline.Head(s, flags, parallel); 589 case DOUBLE_VALUE: return new DoublePipeline.Head(s, flags, parallel); 648 public Sink<T> opWrapSink(int flags, boolean parallel, Sink<T> sink) { argument
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
H A D | FlagDeclaringOp.java | 61 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { argument
|
H A D | StatelessTestOp.java | 81 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink); argument
|
H A D | TestFlagExpectedOp.java | 105 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
|
H A D | CollectorOps.java | 65 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { argument
|
H A D | StatefulTestOp.java | 128 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink); argument
|
H A D | OpTestCase.java | 84 * @param isParallel true if the pipeline is parallel 585 AbstractPipeline createPipeline(StreamShape shape, Spliterator s, int flags, boolean parallel) { argument 587 case REFERENCE: return new ReferencePipeline.Head<>(s, flags, parallel); 588 case INT_VALUE: return new IntPipeline.Head(s, flags, parallel); 589 case LONG_VALUE: return new LongPipeline.Head(s, flags, parallel); 590 case DOUBLE_VALUE: return new DoublePipeline.Head(s, flags, parallel); 649 public Sink<T> opWrapSink(int flags, boolean parallel, Sink<T> sink) { argument
|
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
H A D | FlagOpTest.java | 71 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { argument 264 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument 265 assertFlags(flags, parallel); 269 protected void assertFlags(int flags, boolean parallel) { argument 270 if (parallel) {
|
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
H A D | ConcatTest.java | 145 private void assertRefConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument 147 assertEquals(result.isParallel(), parallel); 151 private void assertIntConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument 154 assertEquals(result.isParallel(), parallel); 159 private void assertLongConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument 162 assertEquals(result.isParallel(), parallel); 167 private void assertDoubleConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument 170 assertEquals(result.isParallel(), parallel); 178 // parallel + parallel [all...] |