Класс Gatherers

public static <TR> Gatherer<TR,?,List<TR>> windowFixed(int windowSize)

// will contain: [[1, 2, 3], [4, 5, 6], [7, 8]]
List<List<Integer>> windows =
    Stream.of(1,2,3,4,5,6,7,8).gather(Gatherers.windowFixed(3)).toList();

Примечание API:

Для повышения эффективности окна могут выделяться непрерывно и заранее. Это означает, что выбор большого размера окна для небольших потоков может привести к чрезмерному расходу памяти во время выполнения этой операции.

Требования к реализации:

Каждое созданное окно представляет собой неизменяемый список; вызов любого метода-мутатора всегда приведёт к выбрасыванию UnsupportedOperationException. Тип реализации и сериализуемость созданных списков не гарантируются.

Параметры типа:

TR — тип элементов, потребляемых возвращаемым сборщиком, и содержимого создаваемых им окон

Параметры:

windowSize — размер окон

Возвращает:

новый сборщик, группирующий элементы в окна фиксированного размера

Выбрасывает:

IllegalArgumentException — если windowSize меньше 1

public static <TR> Gatherer<TR,?,List<TR>> windowSliding(int windowSize)

// will contain: [[1, 2], [2, 3], [3, 4], [4, 5], [5, 6], [6, 7], [7, 8]]
List<List<Integer>> windows2 =
    Stream.of(1,2,3,4,5,6,7,8).gather(Gatherers.windowSliding(2)).toList();

// will contain: [[1, 2, 3, 4, 5, 6], [2, 3, 4, 5, 6, 7], [3, 4, 5, 6, 7, 8]]
List<List<Integer>> windows6 =
    Stream.of(1,2,3,4,5,6,7,8).gather(Gatherers.windowSliding(6)).toList();

Примечание API:

Для повышения эффективности окна могут выделяться непрерывно и заранее. Это означает, что выбор большого размера окна для небольших потоков может привести к чрезмерному расходу памяти во время выполнения этой операции.

Требования к реализации:

Каждое созданное окно представляет собой неизменяемый список; вызов любого метода-мутатора всегда приведёт к выбрасыванию UnsupportedOperationException. Тип реализации и сериализуемость созданных списков не гарантируются.

Параметры типа:

TR — тип элементов, потребляемых возвращаемым сборщиком, и содержимого создаваемых им окон

Параметры:

windowSize — размер окон

Возвращает:

новый сборщик, группирующий элементы в скользящие окна

Выбрасывает:

IllegalArgumentException — если windowSize меньше 1

public static <T,R> Gatherer<T,?,R> fold(Supplier<R> initial, BiFunction<? super R, ? super T, ? extends R> folder)

Требования к реализации:

Если при обработке не возникает исключений, эта операция всегда создаёт только один элемент.

Пример:

// will contain: Optional["123456789"]
Optional<String> numberString =
    Stream.of(1,2,3,4,5,6,7,8,9)
          .gather(
              Gatherers.fold(() -> "", (string, number) -> string + number)
           )
          .findFirst();

Параметры типа:

T — тип элементов, потребляемых возвращаемым сборщиком

R — тип элементов, создаваемых возвращаемым сборщиком

Параметры:

initial — начальное значение для операции свёртки

folder — функция свёртки

Возвращает:

новый Gatherer

Выбрасывает:

NullPointerException — если какой-либо из параметров равен null

См. также:

• Stream.reduce(Object, BinaryOperator)

public static <T,R> Gatherer<T,?,R> scan(Supplier<R> initial, BiFunction<? super R, ? super T, ? extends R> scanner)

// will contain: ["1", "12", "123", "1234", "12345", "123456", "1234567", "12345678", "123456789"]
List<String> numberStrings =
    Stream.of(1,2,3,4,5,6,7,8,9)
          .gather(
              Gatherers.scan(() -> "", (string, number) -> string + number)
           )
          .toList();

Параметры типа:

T — тип элементов, потребляемых этим сборщиком

R — тип элементов, создаваемых этим сборщиком

Параметры:

initial — поставщик начального значения для сканера

scanner — функция, применяемая к каждому элементу

Возвращает:

новый сборщик, выполняющий префиксное сканирование

Выбрасывает:

NullPointerException — если какой-либо из параметров равен null

public static <T,R> Gatherer<T,?,R> mapConcurrent(int maxConcurrency, Function<? super T, ? extends R> mapper)

Примечание API:

Предпринимаются все возможные усилия для отмены выполняющихся задач в ситуациях, когда нижестоящий этап больше не хочет получать элементы.

Требования к реализации:

Если результат функции должен быть передан далее по потоку, но функция завершилась с исключением, этот метод вместо этого повторно выбросит соответствующее исключение как экземпляр RuntimeException, после чего все оставшиеся задачи будут отменены.

Параметры типа:

T — тип входных данных

R — тип выходных данных

Параметры:

maxConcurrency — желаемый максимальный уровень параллелизма

mapper — функция, выполняемая параллельно

Возвращает:

новый Gatherer

Выбрасывает:

IllegalArgumentException — если maxConcurrency меньше 1

NullPointerException — если mapper равен null