/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
D | StreamCloseTest.java | 51 ints.forEach(i -> {}); in testEmptyCloseHandler() 61 ints.forEach(i -> {}); in testOneCloseHandler() 67 ints.forEach(i -> {}); in testOneCloseHandler() 73 ints.forEach(i -> {}); in testOneCloseHandler() 79 ints.forEach(i -> {}); in testOneCloseHandler() 91 ints.forEach(i -> {}); in testTwoCloseHandlers() 97 ints.forEach(i -> {}); in testTwoCloseHandlers() 103 ints.forEach(i -> {}); in testTwoCloseHandlers() 109 ints.forEach(i -> {}); in testTwoCloseHandlers() 123 ints.forEach(i -> {}); in testCascadedExceptions() [all …]
|
D | MapMultiOpTest.java | 68 (e, sink) -> mfNull.apply(e).forEach(sink); 70 (e, sink) -> mfId.apply(e).forEach(sink); 72 (e, sink) -> mfLt.apply(e).forEach(sink); 74 (e, sink) -> flattenChars.apply(e).forEach(sink); 76 (e, sink) -> Stream.empty().forEach(i -> sink.accept((Integer) i)); 78 (e, sink) -> IntStream.range(0, e).boxed().forEach(sink); 80 (e, sink) -> IntStream.range(0, e).boxed().limit(10).forEach(sink); 199 … result = exerciseOps(data, s -> sf.apply(s).mapMulti((i, sink) -> IntStream.of(i).forEach(sink))); in testIntOps() 203 …rciseOps(data, s -> sf.apply(s).boxed().mapMultiToInt((i, sink) -> IntStream.of(i).forEach(sink))); in testIntOps() 207 …result = exerciseOps(data, s -> sf.apply(s).mapMulti((i, sink) -> IntStream.empty().forEach(sink))… in testIntOps() [all …]
|
D | StreamBuilderTest.java | 101 IntStream.range(0, size).boxed().forEach(sb); in testAfterBuilding() 114 IntStream.range(0, s).boxed().forEach(sb); in testStreamBuilder() 120 IntStream.range(0, s).boxed().forEach(i -> { in testStreamBuilder() 164 IntStream.range(0, size).forEach(sb); in testIntAfterBuilding() 177 IntStream.range(0, s).forEach(sb); in testIntStreamBuilder() 183 IntStream.range(0, s).forEach(i -> { in testIntStreamBuilder() 227 LongStream.range(0, size).forEach(sb); in testLongAfterBuilding() 240 LongStream.range(0, s).forEach(sb); in testLongStreamBuilder() 246 LongStream.range(0, s).forEach(i -> { in testLongStreamBuilder() 289 IntStream.range(0, size).asDoubleStream().forEach(sb); in testDoubleAfterBuilding() [all …]
|
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);
|
/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/test/java/util/concurrent/tck/ |
D | ThreadLocalRandom8Test.java | 121 r.ints(size).parallel().forEach(x -> counter.increment()); in testIntsCount() 137 r.longs(size).parallel().forEach(x -> counter.increment()); in testLongsCount() 153 r.doubles(size).parallel().forEach(x -> counter.increment()); in testDoublesCount() 170 r.ints(size, lo, hi).parallel().forEach( in testBoundedInts() 190 r.longs(size, lo, hi).parallel().forEach( in testBoundedLongs() 210 r.doubles(size, lo, hi).parallel().forEach( in testBoundedDoubles() 227 r.ints().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedIntsCount() 239 r.longs().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedLongsCount() 251 r.doubles().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedDoublesCount() 263 r.ints().limit(size).forEach(x -> counter.increment()); in testUnsizedIntsCountSeq() [all …]
|
D | SplittableRandomTest.java | 433 r.ints(size).parallel().forEach(x -> counter.increment()); 449 r.longs(size).parallel().forEach(x -> counter.increment()); 465 r.doubles(size).parallel().forEach(x -> counter.increment()); 482 r.ints(size, lo, hi).parallel().forEach( 502 r.longs(size, lo, hi).parallel().forEach( 522 r.doubles(size, lo, hi).parallel().forEach( 539 r.ints().limit(size).parallel().forEach(x -> counter.increment()); 551 r.longs().limit(size).parallel().forEach(x -> counter.increment()); 563 r.doubles().limit(size).parallel().forEach(x -> counter.increment()); 575 r.ints().limit(size).forEach(x -> counter.increment()); [all …]
|
D | Collection8Test.java | 167 c.forEach(alwaysThrows); 211 () -> c.forEach(null), 359 case 2: c.forEach(survivors::add); break; 525 c.forEach(forEached::add); 526 c.stream().forEach(streamForEached::add); 527 c.parallelStream().forEach(parallelStreamForEached::add); 666 c.stream().forEach(spy); 670 c.stream().forEach(spy); 675 c.stream().forEach(spy); 682 c.stream().forEach(spy); [all …]
|
/libcore/ojluni/src/test/java/time/test/java/time/format/ |
D | TestNarrowMonthNamesAndDayNames.java | 85 LOCARR.forEach((loc) -> { in compareMonthNarrowValues() 86 TEXTSTYLELIST.forEach((style) -> { in compareMonthNarrowValues() 87 MONTHVALUES.forEach((value) -> { in compareMonthNarrowValues() 117 TEXTSTYLELIST.forEach((style) -> { in compareDayNarrowValues() 118 DAYVALUES.forEach((value) -> { in compareDayNarrowValues()
|
/libcore/ojluni/src/test/java/util/Random/ |
D | RandomTest.java | 241 r.ints(size).forEach(x -> { in testIntsCount() 258 r.longs(size).forEach(x -> { in testLongsCount() 275 r.doubles(size).forEach(x -> { in testDoublesCount() 294 forEach(x -> { in testBoundedInts() 314 forEach(x -> { in testBoundedLongs() 334 forEach(x -> { in testBoundedDoubles() 350 r.ints().limit(size).parallel().forEach(x -> { in testUnsizedIntsCount() 363 r.longs().limit(size).parallel().forEach(x -> { in testUnsizedLongsCount() 376 r.doubles().limit(size).parallel().forEach(x -> { in testUnsizedDoublesCount() 389 r.ints().limit(size).forEach(x -> { in testUnsizedIntsCountSeq() [all …]
|
D | RandomTestCoverage.java | 190 .forEach(factory -> { in main() 196 .forEach(factory -> { in main() 201 .forEach(factory -> { in main() 206 .forEach(factory -> { in main() 211 .forEach(factory -> { in main() 216 .forEach(factory -> { in main()
|
D | RandomStreamTest.java | 69 random.ints().limit(count).forEach(destination::add); in testRandomIntStream() 76 random.longs().limit(count).forEach(destination::add); in testRandomLongStream() 83 random.doubles().limit(count).forEach(destination::add); in testRandomDoubleStream() 84 random.doubles().limit(count).forEach(d -> assertTrue(d >= 0.0 && d < 1.0)); in testRandomDoubleStream()
|
/libcore/luni/src/test/java/libcore/java/util/ |
D | PriorityQueueTest.java | 38 assertThrows(NullPointerException.class, () -> pq.forEach(null)); in forEach_throwsNPE_whenConsumerIsNullAndQueueIsEmpty() 47 assertThrows(NullPointerException.class, () -> pq.forEach(null)); in forEach_throwsNPE_whenConsumerIsNullAndQueueIsNotEmpty() 68 pq.forEach(element -> actual.compute(element, in forEach_followPriorityQueueInArbitraryOrder() 80 assertThrows(ConcurrentModificationException.class, () -> pq.forEach(pq::add)); in forEach_throwsCME_ifConsumerModifiesQueue()
|
D | ArrayDequeTest.java | 38 assertThrows(NullPointerException.class, () -> deque.forEach(null)); in forEach_shouldThrowNPE_whenNullConsumer() 47 deque.forEach(actual::add); in forEach_emptyDeque() 62 deque.forEach(actual::add); in forEach_nonEmptyDeque()
|
/libcore/ojluni/src/test/java/util/StringJoiner/ |
D | MergeTest.java | 78 fixesStream().forEach(fixes -> { in testSimple() 90 fixesStream().forEach(fixes -> { in testEmptyOther() 105 fixesStream().forEach(fixes -> { in testEmptyThis() 121 fixesStream().forEach(fixes -> { in testEmptyBoth() 140 fixesStream().forEach(fixes -> { in testCascadeEmpty() 154 fixesStream().forEach(fixes -> { in testDelimiter() 166 fixesStream().forEach(fixes -> { in testMergeSelf()
|
/libcore/ojluni/src/main/java/java/util/stream/ |
D | Node.java | 81 void forEach(Consumer<? super T> consumer); in forEach() method 251 void forEach(T_CONS action); in forEach() method 331 default void forEach(Consumer<? super Integer> consumer) { in forEach() method 333 forEach((IntConsumer) consumer); in forEach() 409 default void forEach(Consumer<? super Long> consumer) { in forEach() method 411 forEach((LongConsumer) consumer); in forEach() 487 default void forEach(Consumer<? super Double> consumer) { in forEach() method 489 forEach((DoubleConsumer) consumer); in forEach()
|
/libcore/ojluni/src/test/java/lang/StackWalker/ |
D | SanityTest.java | 80 StackWalker.getInstance().forEach(null); in testNullConsumer() 90 sw.forEach(StackWalker.StackFrame::getDeclaringClass); in testUOEFromGetDeclaringClass() 100 sw.forEach(StackWalker.StackFrame::getMethodType); in testUOEFromGetMethodType()
|
/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 …]
|
/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 …]
|
/libcore/ojluni/src/test/java/lang/String/CompactString/ |
D | LastIndexOf.java | 69 .forEach( in testLastIndexOf() 115 .forEach( in testLastIndexOf() 156 .forEach( in testLastIndexOf() 214 .forEach( in testLastIndexOf()
|
D | CharAt.java | 59 .forEach( in testCharAt() 63 .forEach( in testCharAt()
|
D | CodePointBefore.java | 65 .forEach( in testCodePointBefore() 69 .forEach( in testCodePointBefore()
|
D | CodePointAt.java | 66 .forEach( in testCodePointAt() 70 .forEach( in testCodePointAt()
|
D | IndexOf.java | 73 map.get(str).forEach( in testIndexOf() 113 .forEach( in testIndexOf() 168 .forEach( in testIndexOf() 238 .forEach( in testIndexOf()
|