Lines Matching defs:accumulator
149 private final BiConsumer<A, T> accumulator;
155 BiConsumer<A, T> accumulator,
160 this.accumulator = accumulator;
167 BiConsumer<A, T> accumulator,
170 this(supplier, accumulator, combiner, castingIdentity(), characteristics);
174 public BiConsumer<A, T> accumulator() {
175 return accumulator;
353 BiConsumer<A, ? super U> downstreamAccumulator = downstream.accumulator();
391 downstream.accumulator(),
905 BiConsumer<A, ? super T> downstreamAccumulator = downstream.accumulator();
906 BiConsumer<Map<K, A>, T> accumulator = (m, t) -> {
916 return new CollectorImpl<>(mangledFactory, accumulator, merger, CH_ID);
927 return new CollectorImpl<>(mangledFactory, accumulator, merger, finisher, CH_NOID);
1056 BiConsumer<A, ? super T> downstreamAccumulator = downstream.accumulator();
1060 BiConsumer<ConcurrentMap<K, A>, T> accumulator;
1062 accumulator = (m, t) -> {
1069 accumulator = (m, t) -> {
1079 return new CollectorImpl<>(mangledFactory, accumulator, merger, CH_CONCURRENT_ID);
1090 return new CollectorImpl<>(mangledFactory, accumulator, merger, finisher, CH_CONCURRENT_NOID);
1137 BiConsumer<A, ? super T> downstreamAccumulator = downstream.accumulator();
1138 BiConsumer<Partition<A>, T> accumulator = (result, t) ->
1148 return new CollectorImpl<>(supplier, accumulator, merger, CH_ID);
1154 return new CollectorImpl<>(supplier, accumulator, merger, finisher, CH_NOID);
1319 BiConsumer<M, T> accumulator
1322 return new CollectorImpl<>(mapSupplier, accumulator, mapMerger(mergeFunction), CH_ID);
1471 BiConsumer<M, T> accumulator
1474 return new CollectorImpl<>(mapSupplier, accumulator, mapMerger(mergeFunction), CH_CONCURRENT_ID);
