/libcore/ojluni/src/main/java/java/util/stream/ |
D | SpinedBuffer.java | 243 public void forEach(Consumer<? super E> consumer) { in forEach() argument 247 consumer.accept(t); in forEach() 251 consumer.accept(curChunk[i]); in forEach() 328 public boolean tryAdvance(Consumer<? super E> consumer) { in spliterator() argument 329 Objects.requireNonNull(consumer); in spliterator() 333 consumer.accept(splChunk[splElementIndex++]); in spliterator() 347 public void forEachRemaining(Consumer<? super E> consumer) { in spliterator() argument 348 Objects.requireNonNull(consumer); in spliterator() 357 consumer.accept(chunk[i]); in spliterator() 365 consumer.accept(chunk[i]); in spliterator() [all …]
|
D | ForEachOps.java | 175 final Consumer<? super T> consumer; field in ForEachOps.ForEachOp.OfRef 177 OfRef(Consumer<? super T> consumer, boolean ordered) { in OfRef() argument 179 this.consumer = consumer; in OfRef() 184 consumer.accept(t); in accept() 191 final IntConsumer consumer; field in ForEachOps.ForEachOp.OfInt 193 OfInt(IntConsumer consumer, boolean ordered) { in OfInt() argument 195 this.consumer = consumer; in OfInt() 205 consumer.accept(t); in accept() 212 final LongConsumer consumer; field in ForEachOps.ForEachOp.OfLong 214 OfLong(LongConsumer consumer, boolean ordered) { in OfLong() argument [all …]
|
D | Streams.java | 83 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument 84 Objects.requireNonNull(consumer); in tryAdvance() 89 consumer.accept(i); in tryAdvance() 94 consumer.accept(i); in tryAdvance() 101 public void forEachRemaining(IntConsumer consumer) { in forEachRemaining() argument 102 Objects.requireNonNull(consumer); in forEachRemaining() 110 consumer.accept(i++); in forEachRemaining() 114 consumer.accept(i); in forEachRemaining() 208 public boolean tryAdvance(LongConsumer consumer) { in tryAdvance() argument 209 Objects.requireNonNull(consumer); in tryAdvance() [all …]
|
D | Node.java | 80 void forEach(Consumer<? super T> consumer); in forEach() argument 325 default void forEach(Consumer<? super Integer> consumer) { in forEach() argument 326 if (consumer instanceof IntConsumer) { in forEach() 327 forEach((IntConsumer) consumer); in forEach() 332 spliterator().forEachRemaining(consumer); in forEach() 398 default void forEach(Consumer<? super Long> consumer) { in forEach() argument 399 if (consumer instanceof LongConsumer) { in forEach() 400 forEach((LongConsumer) consumer); in forEach() 405 spliterator().forEachRemaining(consumer); in forEach() 471 default void forEach(Consumer<? super Double> consumer) { in forEach() argument [all …]
|
D | StreamSpliterators.java | 298 public boolean tryAdvance(Consumer<? super P_OUT> consumer) { in tryAdvance() argument 299 Objects.requireNonNull(consumer); in tryAdvance() 302 consumer.accept(buffer.get(nextToConsume)); in tryAdvance() 307 public void forEachRemaining(Consumer<? super P_OUT> consumer) { in forEachRemaining() argument 309 Objects.requireNonNull(consumer); in forEachRemaining() 312 ph.wrapAndCopyInto((Sink<P_OUT>) consumer::accept, spliterator); in forEachRemaining() 316 do { } while (tryAdvance(consumer)); in forEachRemaining() 356 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument 357 Objects.requireNonNull(consumer); in tryAdvance() 360 consumer.accept(buffer.get(nextToConsume)); in tryAdvance() [all …]
|
D | Nodes.java | 572 public void forEach(T_CONS consumer) { } in forEach() argument 682 public void forEach(Consumer<? super T> consumer) { in forEach() argument 684 consumer.accept(array[i]); in forEach() 730 public void forEach(Consumer<? super T> consumer) { in forEach() argument 731 c.forEach(consumer); in forEach() 811 public void forEach(Consumer<? super T> consumer) { in forEach() argument 812 left.forEach(consumer); in forEach() 813 right.forEach(consumer); in forEach() 851 public void forEach(T_CONS consumer) { in forEach() argument 852 left.forEach(consumer); in forEach() [all …]
|
D | DoublePipeline.java | 370 public void forEach(DoubleConsumer consumer) { 371 evaluate(ForEachOps.makeDouble(consumer, false)); 375 public void forEachOrdered(DoubleConsumer consumer) { 376 evaluate(ForEachOps.makeDouble(consumer, true)); 560 public void forEach(DoubleConsumer consumer) { 562 adapt(sourceStageSpliterator()).forEachRemaining(consumer); 565 super.forEach(consumer); 570 public void forEachOrdered(DoubleConsumer consumer) { 572 adapt(sourceStageSpliterator()).forEachRemaining(consumer); 575 super.forEachOrdered(consumer);
|
/libcore/ojluni/src/main/java/java/util/ |
D | Random.java | 1029 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument 1030 if (consumer == null) throw new NullPointerException(); in tryAdvance() 1033 consumer.accept(rng.internalNextInt(origin, bound)); in tryAdvance() 1040 public void forEachRemaining(IntConsumer consumer) { in forEachRemaining() argument 1041 if (consumer == null) throw new NullPointerException(); in forEachRemaining() 1048 consumer.accept(r.internalNextInt(o, b)); in forEachRemaining() 1084 public boolean tryAdvance(LongConsumer consumer) { in tryAdvance() argument 1085 if (consumer == null) throw new NullPointerException(); in tryAdvance() 1088 consumer.accept(rng.internalNextLong(origin, bound)); in tryAdvance() 1095 public void forEachRemaining(LongConsumer consumer) { in forEachRemaining() argument [all …]
|
D | SplittableRandom.java | 859 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument 860 if (consumer == null) throw new NullPointerException(); in tryAdvance() 863 consumer.accept(rng.internalNextInt(origin, bound)); in tryAdvance() 870 public void forEachRemaining(IntConsumer consumer) { in forEachRemaining() argument 871 if (consumer == null) throw new NullPointerException(); in forEachRemaining() 878 consumer.accept(r.internalNextInt(o, b)); in forEachRemaining() 915 public boolean tryAdvance(LongConsumer consumer) { in tryAdvance() argument 916 if (consumer == null) throw new NullPointerException(); in tryAdvance() 919 consumer.accept(rng.internalNextLong(origin, bound)); in tryAdvance() 926 public void forEachRemaining(LongConsumer consumer) { in forEachRemaining() argument [all …]
|
D | OptionalDouble.java | 135 public void ifPresent(DoubleConsumer consumer) { in ifPresent() argument 137 consumer.accept(value); in ifPresent()
|
D | OptionalInt.java | 136 public void ifPresent(IntConsumer consumer) { in ifPresent() argument 138 consumer.accept(value); in ifPresent()
|
D | OptionalLong.java | 135 public void ifPresent(LongConsumer consumer) { in ifPresent() argument 137 consumer.accept(value); in ifPresent()
|
D | Optional.java | 152 public void ifPresent(Consumer<? super T> consumer) { in ifPresent() argument 154 consumer.accept(value); in ifPresent()
|
D | ArrayDeque.java | 945 public void forEachRemaining(Consumer<? super E> consumer) { in forEachRemaining() argument 946 if (consumer == null) in forEachRemaining() 956 consumer.accept(e); in forEachRemaining() 960 public boolean tryAdvance(Consumer<? super E> consumer) { in tryAdvance() argument 961 if (consumer == null) in tryAdvance() 970 consumer.accept(e); in tryAdvance()
|
D | ArrayList.java | 861 public void forEachRemaining(Consumer<? super E> consumer) { in forEachRemaining() argument 862 Objects.requireNonNull(consumer); in forEachRemaining() 873 consumer.accept((E) elementData[i++]); in forEachRemaining() 1134 public void forEachRemaining(Consumer<? super E> consumer) { in listIterator() argument 1135 Objects.requireNonNull(consumer); in listIterator() 1146 consumer.accept((E) elementData[offset + (i++)]); in listIterator()
|
D | Spliterators.java | 844 public boolean tryAdvance(C consumer) { in tryAdvance() argument 845 Objects.requireNonNull(consumer); in tryAdvance() 849 public void forEachRemaining(C consumer) { in forEachRemaining() argument 850 Objects.requireNonNull(consumer); in forEachRemaining()
|
D | Collections.java | 1906 public void forEach(Consumer<? super E> consumer) { 1907 synchronized (mutex) {c.forEach(consumer);} 3909 public boolean tryAdvance(Consumer<? super T> consumer) { 3910 Objects.requireNonNull(consumer); 3913 consumer.accept(element); 3920 public void forEachRemaining(Consumer<? super T> consumer) { 3921 tryAdvance(consumer);
|
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
D | StreamSpliteratorTest.java | 88 public boolean tryAdvance(Consumer<? super T> consumer) { in tryAdvance() argument 91 return sp.tryAdvance(consumer); in tryAdvance() 95 public void forEachRemaining(Consumer<? super T> consumer) { in forEachRemaining() argument 97 sp.forEachRemaining(consumer); in forEachRemaining() 136 public boolean tryAdvance(Consumer<? super Integer> consumer) { in tryAdvance() argument 137 return Spliterator.OfInt.super.tryAdvance(consumer); in tryAdvance() 141 public void forEachRemaining(Consumer<? super Integer> consumer) { in forEachRemaining() argument 142 Spliterator.OfInt.super.forEachRemaining(consumer); in forEachRemaining() 146 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument 149 return psp.tryAdvance(consumer); in tryAdvance() [all …]
|
D | IntPrimitiveOpsTests.java | 157 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local 158 IntStream.range(1, 1000).sequential().forEach(consumer); in testSequential() 159 assertEquals(expected.length, consumer.getCount()); in testSequential() 163 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local 164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential() 165 assertEquals(expected.length, consumer.getCount()); in testSequential()
|
D | LongPrimitiveOpsTests.java | 157 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local 158 LongStream.range(1, 1000).sequential().forEach(consumer); in testSequential() 159 assertEquals(expected.length, consumer.getCount()); in testSequential() 163 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local 164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential() 165 assertEquals(expected.length, consumer.getCount()); in testSequential()
|
/libcore/luni/src/main/java/java/util/concurrent/ |
D | ThreadLocalRandom.java | 737 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument 738 if (consumer == null) throw new NullPointerException(); in tryAdvance() 741 consumer.accept(ThreadLocalRandom.current().internalNextInt(origin, bound)); in tryAdvance() 748 public void forEachRemaining(IntConsumer consumer) { in forEachRemaining() argument 749 if (consumer == null) throw new NullPointerException(); in forEachRemaining() 756 consumer.accept(rng.internalNextInt(o, b)); in forEachRemaining() 792 public boolean tryAdvance(LongConsumer consumer) { in tryAdvance() argument 793 if (consumer == null) throw new NullPointerException(); in tryAdvance() 796 consumer.accept(ThreadLocalRandom.current().internalNextLong(origin, bound)); in tryAdvance() 803 public void forEachRemaining(LongConsumer consumer) { in forEachRemaining() argument [all …]
|
/libcore/luni/src/test/java/libcore/java/util/ |
D | SpliteratorTester.java | 37 Consumer<T> consumer = (T value) -> recorder.add(value); in runBasicIterationTests() local 40 assertTrue(spliterator.tryAdvance(consumer)); in runBasicIterationTests() 44 spliterator.forEachRemaining(consumer); in runBasicIterationTests() 48 assertFalse(spliterator.tryAdvance(consumer)); in runBasicIterationTests() 55 Consumer<T> consumer = (T value) -> recorder.add(value); in runBasicIterationTests_unordered() local 58 assertTrue(spliterator.tryAdvance(consumer)); in runBasicIterationTests_unordered() 62 spliterator.forEachRemaining(consumer); in runBasicIterationTests_unordered() 68 assertFalse(spliterator.tryAdvance(consumer)); in runBasicIterationTests_unordered()
|