/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
H A D | StreamParSeqTest.java | 40 s = s.sequential(); 43 s = s.sequential();
|
H A D | SequentialOpTest.java | 60 (UnaryOperator<Stream<Integer>>) s -> s.map(id).peek(e -> { counter.incrementAndGet(); }).sequential().map(id), 62 (UnaryOperator<Stream<Integer>>) s -> s.sequential().map(id).peek(e -> { 104 (UnaryOperator<Stream<Integer>>) s -> s.sequential(),
|
H A D | IntPrimitiveOpsTests.java | 158 IntStream.range(1, 1000).sequential().forEach(consumer); 164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer);
|
H A D | LongPrimitiveOpsTests.java | 158 LongStream.range(1, 1000).sequential().forEach(consumer); 164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer);
|
H A D | IntSliceOpTest.java | 201 int[] l = IntStream.range(1, 1001).parallel().skip(200).limit(200).sequential().toArray(); 207 int[] l = IntStream.range(1, 1001).parallel().limit(500).sequential().toArray();
|
/libcore/ojluni/src/main/java/java/util/stream/ |
H A D | BaseStream.java | 37 * sequential and parallel aggregate operations. The following example 94 * Returns an equivalent stream that is sequential. May return 95 * itself, either because the stream was already sequential, or because 96 * the underlying stream state was modified to be sequential. 101 * @return a sequential stream 103 S sequential(); method in interface:BaseStream
|
H A D | DoubleStream.java | 51 * A sequence of primitive double-valued elements supporting sequential and parallel 232 * While {@code limit()} is generally a cheap operation on sequential 242 * {@code limit()} in parallel pipelines, switching to sequential execution 243 * with {@link #sequential()} may improve performance. 261 * While {@code skip()} is generally a cheap operation on sequential 271 * {@code skip()} in parallel pipelines, switching to sequential execution 272 * with {@link #sequential()} may improve performance. 705 DoubleStream sequential(); method in interface:DoubleStream 729 * Returns an empty sequential {@code DoubleStream}. 731 * @return an empty sequential strea [all...] |
H A D | ReferencePipeline.java | 271 result.sequential().forEach(downstream); 299 result.sequential().forEach(downstreamAsInt); 327 result.sequential().forEach(downstreamAsDouble); 355 result.sequential().forEach(downstreamAsLong); 577 // Optimized sequential terminal operations for the head of the pipeline
|
H A D | IntStream.java | 49 * A sequence of primitive int-valued elements supporting sequential and parallel 227 * While {@code limit()} is generally a cheap operation on sequential 237 * {@code limit()} in parallel pipelines, switching to sequential execution 238 * with {@link #sequential()} may improve performance. 256 * While {@code skip()} is generally a cheap operation on sequential 266 * {@code skip()} in parallel pipelines, switching to sequential execution 267 * with {@link #sequential()} may improve performance. 674 IntStream sequential(); method in interface:IntStream 697 * Returns an empty sequential {@code IntStream}. 699 * @return an empty sequential strea [all...] |
H A D | LongStream.java | 53 * A sequence of primitive long-valued elements supporting sequential and parallel 231 * While {@code limit()} is generally a cheap operation on sequential 241 * {@code limit()} in parallel pipelines, switching to sequential execution 242 * with {@link #sequential()} may improve performance. 260 * While {@code skip()} is generally a cheap operation on sequential 270 * {@code skip()} in parallel pipelines, switching to sequential execution 271 * with {@link #sequential()} may improve performance. 666 LongStream sequential(); method in interface:LongStream 689 * Returns an empty sequential {@code LongStream}. 691 * @return an empty sequential strea [all...] |
H A D | AbstractPipeline.java | 57 * <p>For sequential streams, and parallel streams without 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 304 public final S sequential() { method in class:AbstractPipeline 388 * Get the source spliterator for this pipeline stage. For a sequential or
|
H A D | DoublePipeline.java | 273 result.sequential().forEach(i -> downstream.accept(i)); 557 // Optimized sequential terminal operations for the head of the pipeline
|
H A D | LongPipeline.java | 290 result.sequential().forEach(i -> downstream.accept(i)); 537 // Optimized sequential terminal operations for the head of the pipeline
|
H A D | IntPipeline.java | 309 result.sequential().forEach(i -> downstream.accept(i)); 554 // Optimized sequential terminal operations for the head of the pipeline
|
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
H A D | StreamTestScenario.java | 50 s = s.sequential(); 110 // Wrap as parallel stream + sequential 114 m.apply(data.parallelStream()).sequential().forEach(b); 188 // Wrap sequential as parallel, + collect to list 197 // Wrap parallel as sequential,, + collect 201 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList()))
|
H A D | DoubleStreamTestScenario.java | 51 s = s.sequential(); 103 m.apply(data.parallelStream()).sequential().forEach(b);
|
H A D | IntStreamTestScenario.java | 51 s = s.sequential(); 103 m.apply(data.parallelStream()).sequential().forEach(b);
|
H A D | LongStreamTestScenario.java | 51 s = s.sequential(); 103 m.apply(data.parallelStream()).sequential().forEach(b);
|
H A D | OpTestCase.java | 483 return terminalF.apply(source.sequential()); 544 S_OUT out = streamF.apply(data.stream()).sequential();
|
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
H A D | StreamTestScenario.java | 53 s = s.sequential(); 113 // Wrap as parallel stream + sequential 117 m.apply(data.parallelStream()).sequential().forEach(b); 191 // Wrap sequential as parallel, + collect to list 200 // Wrap parallel as sequential,, + collect 204 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList()))
|
H A D | DoubleStreamTestScenario.java | 55 s = s.sequential(); 107 m.apply(data.parallelStream()).sequential().forEach(b);
|
H A D | IntStreamTestScenario.java | 54 s = s.sequential(); 106 m.apply(data.parallelStream()).sequential().forEach(b);
|
H A D | LongStreamTestScenario.java | 54 s = s.sequential(); 106 m.apply(data.parallelStream()).sequential().forEach(b);
|
H A D | OpTestCase.java | 484 return terminalF.apply(source.sequential()); 545 S_OUT out = streamF.apply(data.stream()).sequential();
|