| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | StreamParSeqTest.java | 40 s = s.sequential(); in testParSeq()
43 s = s.sequential(); in testParSeq()
|
| D | SequentialOpTest.java | 60 …or<Stream<Integer>>) s -> s.map(id).peek(e -> { counter.incrementAndGet(); }).sequential().map(id), in testLazy()
62 (UnaryOperator<Stream<Integer>>) s -> s.sequential().map(id).peek(e -> { in testLazy()
104 (UnaryOperator<Stream<Integer>>) s -> s.sequential(), in testMixedSeqPar()
|
| D | IntPrimitiveOpsTests.java | 158 IntStream.range(1, 1000).sequential().forEach(consumer); in testSequential()
164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
|
| D | LongPrimitiveOpsTests.java | 158 LongStream.range(1, 1000).sequential().forEach(consumer); in testSequential()
164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
|
| D | IntSliceOpTest.java | 201 int[] l = IntStream.range(1, 1001).parallel().skip(200).limit(200).sequential().toArray(); in testSkipParallel()
207 int[] l = IntStream.range(1, 1001).parallel().limit(500).sequential().toArray(); in testLimitParallel()
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | BaseStream.java | 105 S sequential(); in sequential() method
|
| D | ReferencePipeline.java | 283 result.sequential().forEach(downstream);
312 result.sequential().forEach(downstreamAsInt);
341 result.sequential().forEach(downstreamAsDouble);
370 result.sequential().forEach(downstreamAsLong);
|
| D | DoubleStream.java | 707 DoubleStream sequential(); in sequential() method
|
| D | IntStream.java | 674 IntStream sequential(); in sequential() method
|
| D | LongStream.java | 667 LongStream sequential(); in sequential() method
|
| D | AbstractPipeline.java | 306 public final S sequential() { in sequential() method in AbstractPipeline
|
| D | IntPipeline.java | 322 result.sequential().forEach(i -> downstream.accept(i));
|
| D | DoublePipeline.java | 285 result.sequential().forEach(i -> downstream.accept(i));
|
| D | LongPipeline.java | 303 result.sequential().forEach(i -> downstream.accept(i));
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| D | StreamTestScenario.java | 50 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
114 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
201 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) in PAR_STREAM_TO_STREAM_COLLECT_TO_LIST()
|
| D | IntStreamTestScenario.java | 51 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
|
| D | DoubleStreamTestScenario.java | 51 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
|
| D | LongStreamTestScenario.java | 51 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
|
| D | OpTestCase.java | 483 return terminalF.apply(source.sequential()); in ALL_PARALLEL_SEQUENTIAL()
544 S_OUT out = streamF.apply(data.stream()).sequential(); in exercise()
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | StreamTestScenario.java | 53 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
117 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
204 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) in PAR_STREAM_TO_STREAM_COLLECT_TO_LIST()
|
| D | IntStreamTestScenario.java | 54 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
106 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
|
| D | DoubleStreamTestScenario.java | 55 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
107 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
|
| D | LongStreamTestScenario.java | 54 s = s.sequential(); in STREAM_FOR_EACH_WITH_CLOSE()
106 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
|
| D | OpTestCase.java | 484 return terminalF.apply(source.sequential()); in ALL_PARALLEL_SEQUENTIAL()
545 S_OUT out = streamF.apply(data.stream()).sequential(); in exercise()
|