Home | History | Annotate | Download | only in stream

Lines Matching refs:accumulator

54  *     <li>incorporating a new data element into a result container ({@link #accumulator()})</li>
65 * accumulator function once for each input element. A parallel implementation
78 * result of any series of accumulator and combiner invocations, {@code a} must
87 * accumulator.accept(a1, t1);
88 * accumulator.accept(a1, t2);
92 * accumulator.accept(a2, t1);
94 * accumulator.accept(a3, t2);
109 * <li>The first argument passed to the accumulator function, both
112 * result supplier, accumulator, or combiner functions.</li>
114 * the result supplier, accumulator, or combiner functions other than to
115 * pass them again to the accumulator, combiner, or finisher functions,
121 * is never passed to the accumulator function again.</li>
123 * supplier, accumulator, or combiner functions must be serially
131 * is one where the accumulator function is called concurrently from
159 * collector.accumulator().accept(container, t);
167 * of the accumulator and combiner functions.)
210 BiConsumer<A, T> accumulator();
245 * {@code accumulator}, and {@code combiner} functions. The resulting
250 * @param accumulator The accumulator function for the new collector
261 BiConsumer<R, T> accumulator,
265 Objects.requireNonNull(accumulator);
272 return new Collectors.CollectorImpl<>(supplier, accumulator, combiner, cs);
277 * {@code accumulator}, {@code combiner}, and {@code finisher} functions.
280 * @param accumulator The accumulator function for the new collector
292 BiConsumer<A, T> accumulator,
297 Objects.requireNonNull(accumulator);
307 return new Collectors.CollectorImpl<>(supplier, accumulator, combiner, finisher, cs);
317 * the result container can support the accumulator function being