/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 | 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 | LongPipeline.java | 303 result.sequential().forEach(i -> downstream.accept(i));
|
/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()
|
/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 | 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 | 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 | 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()
|