Home
last modified time | relevance | path

Searched refs:consumer (Results 1 – 22 of 22) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
DSpinedBuffer.java243 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 …]
DForEachOps.java175 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 …]
DStreams.java83 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 …]
DNode.java80 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 …]
DStreamSpliterators.java298 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 …]
DNodes.java572 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 …]
DDoublePipeline.java370 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/
DRandom.java1029 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 …]
DSplittableRandom.java859 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 …]
DOptionalDouble.java135 public void ifPresent(DoubleConsumer consumer) { in ifPresent() argument
137 consumer.accept(value); in ifPresent()
DOptionalInt.java136 public void ifPresent(IntConsumer consumer) { in ifPresent() argument
138 consumer.accept(value); in ifPresent()
DOptionalLong.java135 public void ifPresent(LongConsumer consumer) { in ifPresent() argument
137 consumer.accept(value); in ifPresent()
DOptional.java152 public void ifPresent(Consumer<? super T> consumer) { in ifPresent() argument
154 consumer.accept(value); in ifPresent()
DArrayDeque.java945 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()
DArrayList.java861 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()
DSpliterators.java844 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()
DCollections.java1906 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/
DStreamSpliteratorTest.java88 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 …]
DIntPrimitiveOpsTests.java157 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()
DLongPrimitiveOpsTests.java157 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/
DThreadLocalRandom.java737 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/
DSpliteratorTester.java37 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()