Lines Matching refs:consumer

298         public boolean tryAdvance(Consumer<? super P_OUT> consumer) {
299 Objects.requireNonNull(consumer);
302 consumer.accept(buffer.get(nextToConsume));
307 public void forEachRemaining(Consumer<? super P_OUT> consumer) {
309 Objects.requireNonNull(consumer);
312 ph.wrapAndCopyInto((Sink<P_OUT>) consumer::accept, spliterator);
316 do { } while (tryAdvance(consumer));
356 public boolean tryAdvance(IntConsumer consumer) {
357 Objects.requireNonNull(consumer);
360 consumer.accept(buffer.get(nextToConsume));
365 public void forEachRemaining(IntConsumer consumer) {
367 Objects.requireNonNull(consumer);
370 ph.wrapAndCopyInto((Sink.OfInt) consumer::accept, spliterator);
374 do { } while (tryAdvance(consumer));
414 public boolean tryAdvance(LongConsumer consumer) {
415 Objects.requireNonNull(consumer);
418 consumer.accept(buffer.get(nextToConsume));
423 public void forEachRemaining(LongConsumer consumer) {
425 Objects.requireNonNull(consumer);
428 ph.wrapAndCopyInto((Sink.OfLong) consumer::accept, spliterator);
432 do { } while (tryAdvance(consumer));
472 public boolean tryAdvance(DoubleConsumer consumer) {
473 Objects.requireNonNull(consumer);
476 consumer.accept(buffer.get(nextToConsume));
481 public void forEachRemaining(DoubleConsumer consumer) {
483 Objects.requireNonNull(consumer);
486 ph.wrapAndCopyInto((Sink.OfDouble) consumer::accept, spliterator);
490 do { } while (tryAdvance(consumer));
525 public boolean tryAdvance(Consumer<? super T> consumer) {
526 return get().tryAdvance(consumer);
530 public void forEachRemaining(Consumer<? super T> consumer) {
531 get().forEachRemaining(consumer);
567 public boolean tryAdvance(T_CONS consumer) {
568 return get().tryAdvance(consumer);
572 public void forEachRemaining(T_CONS consumer) {
573 get().forEachRemaining(consumer);
1082 T_CONS consumer = (T_CONS) this;
1085 if (!s.tryAdvance(consumer))