Home
last modified time | relevance | path

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

/libcore/ojluni/src/main/java/jdk/internal/util/random/
DRandomSupport.java983 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument
984 Objects.requireNonNull(consumer); in tryAdvance()
987 consumer.accept(RandomSupport.boundedNextInt(generatingGenerator, origin, bound)); in tryAdvance()
994 public void forEachRemaining(IntConsumer consumer) { in forEachRemaining() argument
995 Objects.requireNonNull(consumer); in forEachRemaining()
1002 consumer.accept(RandomSupport.boundedNextInt(r, o, b)); in forEachRemaining()
1041 public boolean tryAdvance(LongConsumer consumer) { in tryAdvance() argument
1042 Objects.requireNonNull(consumer); in tryAdvance()
1045 consumer.accept(RandomSupport.boundedNextLong(generatingGenerator, origin, bound)); in tryAdvance()
1052 public void forEachRemaining(LongConsumer consumer) { in forEachRemaining() argument
[all …]
/libcore/ojluni/src/main/java/java/util/stream/
DSpinedBuffer.java246 public void forEach(Consumer<? super E> consumer) { in forEach() argument
250 consumer.accept(t); in forEach()
254 consumer.accept(curChunk[i]); in forEach()
331 public boolean tryAdvance(Consumer<? super E> consumer) { in spliterator() argument
332 Objects.requireNonNull(consumer); in spliterator()
336 consumer.accept(splChunk[splElementIndex++]); in spliterator()
350 public void forEachRemaining(Consumer<? super E> consumer) { in spliterator() argument
351 Objects.requireNonNull(consumer); in spliterator()
360 consumer.accept(chunk[i]); in spliterator()
368 consumer.accept(chunk[i]); in spliterator()
[all …]
DForEachOps.java174 final Consumer<? super T> consumer; field in ForEachOps.ForEachOp.OfRef
176 OfRef(Consumer<? super T> consumer, boolean ordered) { in OfRef() argument
178 this.consumer = consumer; in OfRef()
183 consumer.accept(t); in accept()
190 final IntConsumer consumer; field in ForEachOps.ForEachOp.OfInt
192 OfInt(IntConsumer consumer, boolean ordered) { in OfInt() argument
194 this.consumer = consumer; in OfInt()
204 consumer.accept(t); in accept()
211 final LongConsumer consumer; field in ForEachOps.ForEachOp.OfLong
213 OfLong(LongConsumer consumer, boolean ordered) { in OfLong() argument
[all …]
DStreams.java76 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument
77 Objects.requireNonNull(consumer); in tryAdvance()
82 consumer.accept(i); in tryAdvance()
87 consumer.accept(i); in tryAdvance()
95 public void forEachRemaining(IntConsumer consumer) { in forEachRemaining() argument
96 Objects.requireNonNull(consumer); in forEachRemaining()
104 consumer.accept(i++); in forEachRemaining()
108 consumer.accept(i); in forEachRemaining()
201 public boolean tryAdvance(LongConsumer consumer) { in tryAdvance() argument
202 Objects.requireNonNull(consumer); in tryAdvance()
[all …]
DNode.java81 void forEach(Consumer<? super T> consumer); in forEach() argument
330 default void forEach(Consumer<? super Integer> consumer) { in forEach() argument
331 if (consumer instanceof IntConsumer) { in forEach()
332 forEach((IntConsumer) consumer); in forEach()
337 spliterator().forEachRemaining(consumer); in forEach()
407 default void forEach(Consumer<? super Long> consumer) { in forEach() argument
408 if (consumer instanceof LongConsumer) { in forEach()
409 forEach((LongConsumer) consumer); in forEach()
414 spliterator().forEachRemaining(consumer); in forEach()
484 default void forEach(Consumer<? super Double> consumer) { in forEach() argument
[all …]
DStreamSpliterators.java296 public boolean tryAdvance(Consumer<? super P_OUT> consumer) { in tryAdvance() argument
297 Objects.requireNonNull(consumer); in tryAdvance()
300 consumer.accept(buffer.get(nextToConsume)); in tryAdvance()
305 public void forEachRemaining(Consumer<? super P_OUT> consumer) { in forEachRemaining() argument
307 Objects.requireNonNull(consumer); in forEachRemaining()
310 ph.wrapAndCopyInto((Sink<P_OUT>) consumer::accept, spliterator); in forEachRemaining()
314 do { } while (tryAdvance(consumer)); in forEachRemaining()
354 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument
355 Objects.requireNonNull(consumer); in tryAdvance()
358 consumer.accept(buffer.get(nextToConsume)); in tryAdvance()
[all …]
DNodes.java580 public void forEach(T_CONS consumer) { } in forEach() argument
690 public void forEach(Consumer<? super T> consumer) { in forEach() argument
692 consumer.accept(array[i]); in forEach()
738 public void forEach(Consumer<? super T> consumer) { in forEach() argument
739 c.forEach(consumer); in forEach()
819 public void forEach(Consumer<? super T> consumer) { in forEach() argument
820 left.forEach(consumer); in forEach()
821 right.forEach(consumer); in forEach()
859 public void forEach(T_CONS consumer) { in forEach() argument
860 left.forEach(consumer); in forEach()
[all …]
DDoublePipeline.java448 public void forEach(DoubleConsumer consumer) {
449 evaluate(ForEachOps.makeDouble(consumer, false));
453 public void forEachOrdered(DoubleConsumer consumer) {
454 evaluate(ForEachOps.makeDouble(consumer, true));
646 public void forEach(DoubleConsumer consumer) {
648 adapt(sourceStageSpliterator()).forEachRemaining(consumer);
651 super.forEach(consumer);
656 public void forEachOrdered(DoubleConsumer consumer) {
658 adapt(sourceStageSpliterator()).forEachRemaining(consumer);
661 super.forEachOrdered(consumer);
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DStreamSpliteratorTest.java92 public boolean tryAdvance(Consumer<? super T> consumer) { in tryAdvance() argument
95 return sp.tryAdvance(consumer); in tryAdvance()
99 public void forEachRemaining(Consumer<? super T> consumer) { in forEachRemaining() argument
101 sp.forEachRemaining(consumer); in forEachRemaining()
140 public boolean tryAdvance(Consumer<? super Integer> consumer) { in tryAdvance() argument
141 return Spliterator.OfInt.super.tryAdvance(consumer); in tryAdvance()
145 public void forEachRemaining(Consumer<? super Integer> consumer) { in forEachRemaining() argument
146 Spliterator.OfInt.super.forEachRemaining(consumer); in forEachRemaining()
150 public boolean tryAdvance(IntConsumer consumer) { in tryAdvance() argument
153 return psp.tryAdvance(consumer); in tryAdvance()
[all …]
DLongPrimitiveOpsTests.java205 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local
206 LongStream.range(1, 1000).sequential().forEach(consumer); in testSequential()
207 assertEquals(expected.length, consumer.getCount()); in testSequential()
211 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local
212 LongStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
213 assertEquals(expected.length, consumer.getCount()); in testSequential()
DIntPrimitiveOpsTests.java217 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local
218 IntStream.range(1, 1000).sequential().forEach(consumer); in testSequential()
219 assertEquals(expected.length, consumer.getCount()); in testSequential()
223 AssertingConsumer consumer = new AssertingConsumer(expected); in testSequential() local
224 IntStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
225 assertEquals(expected.length, consumer.getCount()); in testSequential()
/libcore/ojluni/annotations/hiddenapi/java/util/
DRandom.java237 public boolean tryAdvance(java.util.function.DoubleConsumer consumer) { in tryAdvance() argument
241 public void forEachRemaining(java.util.function.DoubleConsumer consumer) { in forEachRemaining() argument
291 public boolean tryAdvance(java.util.function.IntConsumer consumer) { in tryAdvance() argument
295 public void forEachRemaining(java.util.function.IntConsumer consumer) { in forEachRemaining() argument
346 public boolean tryAdvance(java.util.function.LongConsumer consumer) { in tryAdvance() argument
350 public void forEachRemaining(java.util.function.LongConsumer consumer) { in forEachRemaining() argument
DArrayDeque.java270 public void forEachRemaining(java.util.function.Consumer<? super E> consumer) { in forEachRemaining() argument
274 public boolean tryAdvance(java.util.function.Consumer<? super E> consumer) { in tryAdvance() argument
DArrayList.java303 public void forEachRemaining(java.util.function.Consumer<? super E> consumer) { in forEachRemaining() argument
DCollections.java2249 public void forEach(java.util.function.Consumer<? super E> consumer) { in forEach() argument
/libcore/luni/src/test/java/libcore/java/util/
DSpliteratorTester.java46 Consumer<T> consumer = (T value) -> recorder.add(value); in runBasicIterationTests() local
49 boolean didAdvance = spliterator.tryAdvance(consumer); in runBasicIterationTests()
53 spliterator.forEachRemaining(consumer); in runBasicIterationTests()
57 assertFalse(spliterator.tryAdvance(consumer)); in runBasicIterationTests()
64 Consumer<T> consumer = (T value) -> recorder.add(value); in runBasicIterationTests_unordered() local
68 assertFalse(spliterator.tryAdvance(consumer)); in runBasicIterationTests_unordered()
70 assertTrue(spliterator.tryAdvance(consumer)); in runBasicIterationTests_unordered()
75 spliterator.forEachRemaining(consumer); in runBasicIterationTests_unordered()
81 assertFalse(spliterator.tryAdvance(consumer)); in runBasicIterationTests_unordered()
/libcore/ojluni/src/main/java/java/util/concurrent/
DSubmissionPublisher.java921 public CompletableFuture<Void> consume(Consumer<? super T> consumer) { in consume() argument
922 if (consumer == null) in consume()
925 subscribe(new ConsumerSubscriber<T>(status, consumer)); in consume()
932 final Consumer<? super T> consumer; field in SubmissionPublisher.ConsumerSubscriber
935 Consumer<? super T> consumer) { in ConsumerSubscriber() argument
936 this.status = status; this.consumer = consumer; in ConsumerSubscriber()
952 consumer.accept(item); in onNext()
971 final BufferedSubscription<T> consumer; field in SubmissionPublisher.ConsumerTask
972 ConsumerTask(BufferedSubscription<T> consumer) { in ConsumerTask() argument
973 this.consumer = consumer; in ConsumerTask()
[all …]
/libcore/ojluni/src/test/java/util/stream/examples/
DJavadocExamples.java48 List<Integer> integers = numbers.<Integer>mapMulti((number, consumer) -> { in testNumberIntegerExample()
50 consumer.accept((Integer)number); in testNumberIntegerExample()
/libcore/libart/src/main/java/dalvik/system/
DVMRuntime.java1008 public static void setNonSdkApiUsageConsumer(Consumer<String> consumer) { in setNonSdkApiUsageConsumer() argument
1009 nonSdkApiUsageConsumer = consumer; in setNonSdkApiUsageConsumer()
/libcore/ojluni/src/main/java/java/util/
DSpliterators.java888 public boolean tryAdvance(C consumer) { in tryAdvance() argument
889 Objects.requireNonNull(consumer); in tryAdvance()
893 public void forEachRemaining(C consumer) { in forEachRemaining() argument
894 Objects.requireNonNull(consumer); in forEachRemaining()
DCollections.java2414 public void forEach(Consumer<? super E> consumer) {
2415 synchronized (mutex) {c.forEach(consumer);}
5150 public boolean tryAdvance(Consumer<? super T> consumer) {
5151 Objects.requireNonNull(consumer);
5154 consumer.accept(element);
5161 public void forEachRemaining(Consumer<? super T> consumer) {
5162 tryAdvance(consumer);