| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | Collector.java | 210 BiConsumer<A, T> accumulator(); in accumulator() method
261 BiConsumer<R, T> accumulator, in of() argument
265 Objects.requireNonNull(accumulator); in of()
272 return new Collectors.CollectorImpl<>(supplier, accumulator, combiner, cs); in of()
292 BiConsumer<A, T> accumulator, in of() argument
297 Objects.requireNonNull(accumulator); in of()
307 return new Collectors.CollectorImpl<>(supplier, accumulator, combiner, finisher, cs); in of()
|
| D | Collectors.java | 149 private final BiConsumer<A, T> accumulator; field in CollectorImpl
155 BiConsumer<A, T> accumulator, in CollectorImpl() argument
160 this.accumulator = accumulator; in CollectorImpl()
167 BiConsumer<A, T> accumulator, in CollectorImpl() argument
170 this(supplier, accumulator, combiner, castingIdentity(), characteristics); in CollectorImpl()
174 public BiConsumer<A, T> accumulator() { in accumulator() method in CollectorImpl
175 return accumulator; in accumulator()
353 BiConsumer<A, ? super U> downstreamAccumulator = downstream.accumulator();
391 downstream.accumulator(),
905 BiConsumer<A, ? super T> downstreamAccumulator = downstream.accumulator();
[all …]
|
| D | ReduceOps.java | 158 BiConsumer<I, ? super T> accumulator = collector.accumulator();
169 accumulator.accept(state, t);
206 BiConsumer<R, ? super T> accumulator,
209 Objects.requireNonNull(accumulator);
220 accumulator.accept(state, t);
342 ObjIntConsumer<R> accumulator,
345 Objects.requireNonNull(accumulator);
356 accumulator.accept(state, t);
478 ObjLongConsumer<R> accumulator,
481 Objects.requireNonNull(accumulator);
[all …]
|
| D | ReferencePipeline.java | 475 public final P_OUT reduce(final P_OUT identity, final BinaryOperator<P_OUT> accumulator) {
476 return evaluate(ReduceOps.makeRef(identity, accumulator, accumulator));
480 public final Optional<P_OUT> reduce(BinaryOperator<P_OUT> accumulator) {
481 return evaluate(ReduceOps.makeRef(accumulator));
485 …public final <R> R reduce(R identity, BiFunction<R, ? super P_OUT, R> accumulator, BinaryOperator<…
486 return evaluate(ReduceOps.makeRef(identity, accumulator, combiner));
497 BiConsumer<A, ? super P_OUT> accumulator = collector.accumulator();
498 forEach(u -> accumulator.accept(container, u));
510 BiConsumer<R, ? super P_OUT> accumulator,
512 return evaluate(ReduceOps.makeRef(supplier, accumulator, combiner));
|
| D | Stream.java | 604 T reduce(T identity, BinaryOperator<T> accumulator); in reduce() argument
644 Optional<T> reduce(BinaryOperator<T> accumulator); in reduce() argument
694 BiFunction<U, ? super T, U> accumulator, in reduce() argument
749 BiConsumer<R, ? super T> accumulator, in collect() argument
|
| D | DoubleStream.java | 452 ObjDoubleConsumer<R> accumulator, in collect() argument
|
| D | IntStream.java | 446 ObjIntConsumer<R> accumulator, in collect() argument
|
| D | DoublePipeline.java | 471 ObjDoubleConsumer<R> accumulator,
477 return evaluate(ReduceOps.makeDouble(supplier, accumulator, operator));
|
| D | LongPipeline.java | 449 ObjLongConsumer<R> accumulator,
455 return evaluate(ReduceOps.makeLong(supplier, accumulator, operator));
|
| D | IntPipeline.java | 467 ObjIntConsumer<R> accumulator,
473 return evaluate(ReduceOps.makeInt(supplier, accumulator, operator));
|
| D | LongStream.java | 450 ObjLongConsumer<R> accumulator, in collect() argument
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | GroupByOpTest.java | 69 collector.accumulator().accept(m, i); in testBypassCollect()
|