Главная / Streams / Stream Gatherers
Streams Продвинутый

Stream Gatherers

Использование Gatherers для пользовательских промежуточных операций Stream.

Сравнение кода
✕ Java 8 
// Sliding window: manual implementation
List<List<T>> windows = new ArrayList<>();
for (int i = 0; i <= list.size()-3; i++) {
    windows.add(
        list.subList(i, i + 3));
}
✓ Java 24+ 
var windows = stream
    .gather(
        Gatherers.windowSliding(3)
    )
    .toList();
Заметили проблему в этом коде? Сообщите нам.
Почему современный подход лучше
🧩

Компонуемый

Gatherers сочетаются с другими операциями Stream.

📦

Встроенные операции

windowFixed, windowSliding, fold, scan доступны из коробки.

🔧

Расширяемый

Написание собственных Gatherers для любых промежуточных преобразований.

Старый подход
Пользовательский Collector
Современный подход
gather()
Начиная с JDK
24
Сложность
Продвинутый
Поддержка JDK
Stream Gatherers
Доступно

Финализировано в JDK 24 (JEP 485, март 2025).

Как это работает

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

Связанная документация
Stream Gatherers (JEP 485) ↗ Gatherers ↗
Доказательство
Посмотреть исходник доказательства ↗
Похожие шаблоны
Streams Начинающий

Stream.ofNullable()

Java 8
Stream<String> s = val != null
    ? Stream.of(val)
    : Stream.empty();
Java 9+
Stream<String> s =
    Stream.ofNullable(val);
Наведите, чтобы увидеть современный ➜
JDK 9+ →
Streams Средний

Stream.iterate() with predicate

Java 8
Stream.iterate(1, n -> n * 2)
    .limit(10)
    .forEach(System.out::println);
// can't stop at a condition
Java 9+
Stream.iterate(
    1,
    n -> n < 1000,
    n -> n * 2
).forEach(IO::println);
// stops when n >= 1000
Наведите, чтобы увидеть современный ➜
JDK 9+ →
Streams Начинающий

Stream takeWhile / dropWhile

Java 8
List<Integer> result = new ArrayList<>();
for (int n : sorted) {
    if (n >= 100) break;
    result.add(n);
}
// no stream equivalent in Java 8
Java 9+
var result = sorted.stream()
    .takeWhile(n -> n < 100)
    .toList();
// or: .dropWhile(n -> n < 10)
Наведите, чтобы увидеть современный ➜
JDK 9+ →