Searched refs:sequential (Results 1 - 24 of 24) sorted by relevance

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DStreamParSeqTest.java40 s = s.sequential();
43 s = s.sequential();
H A DSequentialOpTest.java60 (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 DIntPrimitiveOpsTests.java158 IntStream.range(1, 1000).sequential().forEach(consumer);
164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer);
H A DLongPrimitiveOpsTests.java158 LongStream.range(1, 1000).sequential().forEach(consumer);
164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer);
H A DIntSliceOpTest.java201 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 DBaseStream.java37 * 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 DDoubleStream.java51 * 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 DReferencePipeline.java271 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 DIntStream.java49 * 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 DLongStream.java53 * 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 DAbstractPipeline.java57 * <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 DDoublePipeline.java273 result.sequential().forEach(i -> downstream.accept(i));
557 // Optimized sequential terminal operations for the head of the pipeline
H A DLongPipeline.java290 result.sequential().forEach(i -> downstream.accept(i));
537 // Optimized sequential terminal operations for the head of the pipeline
H A DIntPipeline.java309 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 DStreamTestScenario.java50 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 DDoubleStreamTestScenario.java51 s = s.sequential();
103 m.apply(data.parallelStream()).sequential().forEach(b);
H A DIntStreamTestScenario.java51 s = s.sequential();
103 m.apply(data.parallelStream()).sequential().forEach(b);
H A DLongStreamTestScenario.java51 s = s.sequential();
103 m.apply(data.parallelStream()).sequential().forEach(b);
H A DOpTestCase.java483 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 DStreamTestScenario.java53 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 DDoubleStreamTestScenario.java55 s = s.sequential();
107 m.apply(data.parallelStream()).sequential().forEach(b);
H A DIntStreamTestScenario.java54 s = s.sequential();
106 m.apply(data.parallelStream()).sequential().forEach(b);
H A DLongStreamTestScenario.java54 s = s.sequential();
106 m.apply(data.parallelStream()).sequential().forEach(b);
H A DOpTestCase.java484 return terminalF.apply(source.sequential());
545 S_OUT out = streamF.apply(data.stream()).sequential();

Completed in 262 milliseconds