Реализация Java Collectors.reduction

Функция принимает три аргумента:

• Первый — это личность. При сокращении потока нужно с чего-то начинать (иначе, какой будет результат сокращения пустого списка?). Идентификатор — это объект, применяемый к первому аргументу первой операции редукции в цепочке.

• Второй — картограф. reducing() — это обобщенная операция — вы можете свести элементы потока типа T к конечному результату типа U, поэтому вам нужно дать промежуточную операцию, которая предоставляет элемент типа U из элемента типа T. Если T == U и вы не хотите преобразования, вы можете указать здесь функцию идентификации

• Третий аргумент — функция редукции — она применяется к элементам потока последовательно, начиная с личность.

Итак, в качестве примера:

Если вы хотите просто суммировать элементы потока Integer в целое число, вы можете использовать Collectors.reducing(0, x -> x, (x, y) -> x + y).

Если вы хотите суммировать длины String в потоке String, вы можете использовать Collectors.reducing(0, String::length, (x, y) -> x + y).

Если вы хотите получить максимум Double из строки Doubles, но не меньше Math.PI, вы можете использовать Collectors.reducing(Math.PI, x -> x, Math::max).

Кроме того, если вы хотите, чтобы ваша редукция сохраняла состояние, помните, что вы можете использовать в качестве редуктора ссылку на метод внутри объекта. Таким образом, объект можно использовать для сохранения состояния. Например, вот «уменьшитель налогов», который добавляет 1 «налог» к своему счету каждые 100 добавлений:

public class Taxer implements BinaryOperator<Integer> {
 int counter = 0;

 @Override
 public Integer apply(Integer i1, Integer i2) {
  counter++;
  if (counter % 100 == 0) {
   return i1 + i2 + 1;
  } else {
   return i1 + i2;
  }
 }
}

...

Taxer t = new Taxer();

...

.collect(Collectors.reducing(0, x -> x, t);

То же самое можно расширить, используя для реализации сложных случаев, таких как groupingBy:

Map<String, Integer> output = Stream.of("this", "word", "is", "the", "best")
    .collect(Collectors.groupingBy(x-> x.substring(0, 1),
            Collectors.reducing(0, x-> x.length(), (x, y)-> x + y)));

Здесь сначала входная строка группируется на основе символа, с которого она начинается, а затем суммируются длины