| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | StreamCloseTest.java | 43 ints.forEach(i -> {}); in testEmptyCloseHandler()
53 ints.forEach(i -> {}); in testOneCloseHandler()
59 ints.forEach(i -> {}); in testOneCloseHandler()
65 ints.forEach(i -> {}); in testOneCloseHandler()
71 ints.forEach(i -> {}); in testOneCloseHandler()
83 ints.forEach(i -> {}); in testTwoCloseHandlers()
89 ints.forEach(i -> {}); in testTwoCloseHandlers()
95 ints.forEach(i -> {}); in testTwoCloseHandlers()
101 ints.forEach(i -> {}); in testTwoCloseHandlers()
115 ints.forEach(i -> {}); in testCascadedExceptions()
[all …]
|
| D | StreamBuilderTest.java | 94 IntStream.range(0, size).boxed().forEach(sb); in testAfterBuilding()
106 IntStream.range(0, s).boxed().forEach(sb); in testStreamBuilder()
112 IntStream.range(0, s).boxed().forEach(i -> { in testStreamBuilder()
156 IntStream.range(0, size).forEach(sb); in testIntAfterBuilding()
168 IntStream.range(0, s).forEach(sb); in testIntStreamBuilder()
174 IntStream.range(0, s).forEach(i -> { in testIntStreamBuilder()
218 LongStream.range(0, size).forEach(sb); in testLongAfterBuilding()
230 LongStream.range(0, s).forEach(sb); in testLongStreamBuilder()
236 LongStream.range(0, s).forEach(i -> { in testLongStreamBuilder()
279 IntStream.range(0, size).asDoubleStream().forEach(sb); in testDoubleAfterBuilding()
[all …]
|
| D | CountTest.java | 53 data.stream().forEach(e -> expectedCount.incrementAndGet()); in testOps()
64 data.stream().forEach(e -> expectedCount.incrementAndGet()); in testOps()
75 data.stream().forEach(e -> expectedCount.incrementAndGet()); in testOps()
86 data.stream().forEach(e -> expectedCount.incrementAndGet()); in testOps()
|
| D | ForEachOpTest.java | 61 s.forEach(e -> count.incrementAndGet()); in testForEach()
69 s.forEach(sum::addAndGet); in testForEach()
114 s.forEach(l::add);
162 s.forEach(l::add);
210 s.forEach(l::add);
258 s.forEach(l::add);
|
| D | IntPrimitiveOpsTests.java | 66 IntStream.range(1, 10).filter(i -> i % 2 == 0).forEach(i -> { sum[0] = sum[0] + i; }); in testForEach()
73 IntStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
158 IntStream.range(1, 1000).sequential().forEach(consumer); in testSequential()
164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
|
| D | LongPrimitiveOpsTests.java | 66 LongStream.range(1, 10).filter(i -> i % 2 == 0).forEach(i -> { sum[0] = sum[0] + i; }); in testForEach()
73 LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
158 LongStream.range(1, 1000).sequential().forEach(consumer); in testSequential()
164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ThreadLocalRandom8Test.java | 81 r.ints(size).parallel().forEach(x -> counter.increment()); in testIntsCount()
96 r.longs(size).parallel().forEach(x -> counter.increment()); in testLongsCount()
111 r.doubles(size).parallel().forEach(x -> counter.increment()); in testDoublesCount()
127 r.ints(size, lo, hi).parallel().forEach( in testBoundedInts()
146 r.longs(size, lo, hi).parallel().forEach( in testBoundedLongs()
165 r.doubles(size, lo, hi).parallel().forEach( in testBoundedDoubles()
181 r.ints().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedIntsCount()
192 r.longs().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedLongsCount()
203 r.doubles().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedDoublesCount()
214 r.ints().limit(size).forEach(x -> counter.increment()); in testUnsizedIntsCountSeq()
[all …]
|
| D | Collection8Test.java | 55 c.stream().forEach(spy); in testForEach()
59 c.stream().forEach(spy); in testForEach()
64 c.stream().forEach(spy); in testForEach()
71 c.stream().forEach(spy); in testForEach()
88 c.stream().forEach((x) -> { assertSame(x, elt); }); }; in testForEachConcurrentStressTest()
|
| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | Node.java | 81 void forEach(Consumer<? super T> consumer); in forEach() method
247 void forEach(T_CONS action); in forEach() method
326 default void forEach(Consumer<? super Integer> consumer) { in forEach() method
328 forEach((IntConsumer) consumer); in forEach()
399 default void forEach(Consumer<? super Long> consumer) { in forEach() method
401 forEach((LongConsumer) consumer); in forEach()
472 default void forEach(Consumer<? super Double> consumer) { in forEach() method
474 forEach((DoubleConsumer) consumer); in forEach()
|
| D | Nodes.java | 572 public void forEach(T_CONS consumer) { } in forEach() method in Nodes.EmptyNode
682 public void forEach(Consumer<? super T> consumer) { in forEach() method in Nodes.ArrayNode
730 public void forEach(Consumer<? super T> consumer) { in forEach() method in Nodes.CollectionNode
731 c.forEach(consumer); in forEach()
811 public void forEach(Consumer<? super T> consumer) { in forEach() method in Nodes.ConcNode
812 left.forEach(consumer); in forEach()
813 right.forEach(consumer); in forEach()
851 public void forEach(T_CONS consumer) { in forEach() method in Nodes.ConcNode.OfPrimitive
852 left.forEach(consumer); in forEach()
853 right.forEach(consumer); in forEach()
[all …]
|
| D | ReferencePipeline.java | 283 result.sequential().forEach(downstream);
312 result.sequential().forEach(downstreamAsInt);
341 result.sequential().forEach(downstreamAsDouble);
370 result.sequential().forEach(downstreamAsLong);
434 public void forEach(Consumer<? super P_OUT> action) {
514 forEach(u -> accumulator.accept(container, u));
602 public void forEach(Consumer<? super E_OUT> action) {
607 super.forEach(action);
|
| D | SpinedBuffer.java | 246 public void forEach(Consumer<? super E> consumer) { in forEach() method in SpinedBuffer
273 forEach(list::add); in toString()
472 public abstract void forEach(Consumer<? super E> consumer); in forEach() method in SpinedBuffer.OfPrimitive
591 public void forEach(T_CONS consumer) { in forEach() method in SpinedBuffer.OfPrimitive
740 public void forEach(Consumer<? super Integer> consumer) { in forEach() method in SpinedBuffer.OfInt
742 forEach((IntConsumer) consumer); in forEach()
857 public void forEach(Consumer<? super Long> consumer) { in forEach() method in SpinedBuffer.OfLong
859 forEach((LongConsumer) consumer); in forEach()
976 public void forEach(Consumer<? super Double> consumer) { in forEach() method in SpinedBuffer.OfDouble
978 forEach((DoubleConsumer) consumer); in forEach()
|
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| D | SpinedBufferTest.java | 68 Arrays.stream(array).boxed().forEach(sb); in createSpinedBuffer()
72 Arrays.stream(array).boxed().forEach(sb); in createSpinedBuffer()
76 Arrays.stream(array).boxed().forEach(sb); in createSpinedBuffer()
80 Arrays.stream(array).boxed().forEach(sb); in createSpinedBuffer()
136 sb.forEach(list2::add); in testSpinedBuffer()
154 Arrays.stream(array).forEach(sb); in createIntSpinedBuffer()
211 sb.forEach((int i) -> list2.add(i)); in testIntSpinedBuffer()
229 Arrays.stream(array).forEach(sb); in createLongSpinedBuffer()
286 sb.forEach((long i) -> list2.add(i)); in testLongSpinedBuffer()
305 Arrays.stream(array).forEach(sb); in createDoubleSpinedBuffer()
[all …]
|
| D | NodeBuilderTest.java | 85 n.forEach(_l::add); in testIteration()
130 n.forEach((IntConsumer) _l::add); in testIntIteration()
180 n.forEach((LongConsumer) _l::add); in testLongIteration()
230 n.forEach((DoubleConsumer) _l::add); in testDoubleIteration()
|
| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/util/ |
| D | WeakHashMapTest.java | 417 map.forEach((k, v) -> output.put(k,v)); in test_forEach()
421 map.keySet().forEach((k) -> setOutput.add(k)); in test_forEach()
425 map.values().forEach((v) -> setOutput.add(v)); in test_forEach()
429 map.entrySet().forEach((v) -> entrySetOutput.add(v)); in test_forEach()
436 map.forEach(null); in test_forEach_NPE()
441 map.keySet().forEach(null); in test_forEach_NPE()
446 map.values().forEach(null); in test_forEach_NPE()
451 map.entrySet().forEach(null); in test_forEach_NPE()
463 map.forEach(new java.util.function.BiConsumer<Object, Object>() { in test_forEach_CME()
477 map.keySet().forEach(new java.util.function.Consumer<Object>() { in test_forEach_CME()
[all …]
|
| D | LinkedHashMapTest.java | 721 map.forEach((k, v) -> output.put(k,v)); in test_forEach()
725 map.keySet().forEach((k) -> setOutput.add(k)); in test_forEach()
729 map.values().forEach((v) -> setOutput.add(v)); in test_forEach()
733 map.entrySet().forEach((v) -> entrySetOutput.add(v)); in test_forEach()
741 map.forEach(null); in test_forEach_NPE()
746 map.keySet().forEach(null); in test_forEach_NPE()
751 map.values().forEach(null); in test_forEach_NPE()
756 map.entrySet().forEach(null); in test_forEach_NPE()
769 map.forEach(new java.util.function.BiConsumer<String, String>() { in test_forEach_CME()
783 map.keySet().forEach(new java.util.function.Consumer<String>() { in test_forEach_CME()
[all …]
|
| D | HashMapTest.java | 705 map.forEach((k, v) -> output.put(k,v)); in test_forEach()
709 map.keySet().forEach((k) -> setOutput.add(k)); in test_forEach()
713 map.values().forEach((v) -> setOutput.add(v)); in test_forEach()
717 map.entrySet().forEach((v) -> entrySetOutput.add(v)); in test_forEach()
724 map.forEach(null); in test_forEach_NPE()
729 map.keySet().forEach(null); in test_forEach_NPE()
734 map.values().forEach(null); in test_forEach_NPE()
739 map.entrySet().forEach(null); in test_forEach_NPE()
752 map.forEach(new java.util.function.BiConsumer<String, String>() { in test_forEach_CME()
766 map.keySet().forEach(new java.util.function.Consumer<String>() { in test_forEach_CME()
[all …]
|
| D | Collections2Test.java | 500 collection.forEach(k -> output.add(k)); in testCollectionForEach()
518 map.forEach((k, v) -> output.put(k, v)); in testMapForEach()
522 map.entrySet().forEach(entry -> output.put(entry.getKey(), entry.getValue())); in testMapForEach()
526 map.values().forEach(value -> setOutput.add(value)); in testMapForEach()
530 map.keySet().forEach((k) -> setOutput.add(k)); in testMapForEach()
547 set.forEach(k -> output.add(k)); in testSetForEach()
581 queue.forEach(v -> output.add(v)); in test_Queue_forEach()
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | IntStreamTestScenario.java | 56 s.forEach(b); in STREAM_FOR_EACH_WITH_CLOSE()
106 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
175 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
189 m.apply(pipe1).forEach(e -> { in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
|
| D | DoubleStreamTestScenario.java | 57 s.forEach(b); in STREAM_FOR_EACH_WITH_CLOSE()
107 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
175 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
189 m.apply(pipe1).forEach(e -> { in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
|
| D | LongStreamTestScenario.java | 56 s.forEach(b); in STREAM_FOR_EACH_WITH_CLOSE()
106 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
174 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
188 m.apply(pipe1).forEach(e -> { in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
|
| /libcore/ojluni/annotations/hiddenapi/java/util/ |
| D | LinkedHashMap.java | 139 public void forEach(java.util.function.BiConsumer<? super K, ? super V> action) { in forEach() method in LinkedHashMap
201 public void forEach(java.util.function.Consumer<? super java.util.Map.Entry<K, V>> action) { in forEach() method in LinkedHashMap.LinkedEntrySet
285 public void forEach(java.util.function.Consumer<? super K> action) { in forEach() method in LinkedHashMap.LinkedKeySet
326 public void forEach(java.util.function.Consumer<? super V> action) { in forEach() method in LinkedHashMap.LinkedValues
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| D | IntStreamTestScenario.java | 53 s.forEach(b); in STREAM_FOR_EACH_WITH_CLOSE()
103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
172 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
186 m.apply(pipe1).forEach(e -> { in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
|
| D | DoubleStreamTestScenario.java | 53 s.forEach(b); in STREAM_FOR_EACH_WITH_CLOSE()
103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
171 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
185 m.apply(pipe1).forEach(e -> { in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
|
| D | LongStreamTestScenario.java | 53 s.forEach(b); in STREAM_FOR_EACH_WITH_CLOSE()
103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
171 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
185 m.apply(pipe1).forEach(e -> { in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
|