Неожиданное поведение функции предварительного просмотра Java 22 Stream Gatherer: последний элемент в потоке опущен ⇐ JAVA

[Anonymous]

Я изучаю Java Stream Gatherers — функцию предварительной версии, представленную в Java 22, и использую Java 23 с включенными для этой цели функциями предварительной версии. Моя основная цель здесь — лучше понять, как работает Gatherer API, а не просто решить проблему «различия по коду продукта».
В моем коде я ожидаю собрать три отдельных объекта Offer. на основе их ProductCode, но я постоянно получаю только 2. Отладка показывает, что сборщик всегда пропускает последний элемент в потоке. Когда я увеличиваю количество предложений до 4, размер результата становится равным 3, но последний элемент все равно пропускается.
Я не уверен, что неправильно понимаю, как работает Gatherer API. должно работать, или в реализации этой функции предварительной версии JDK может быть ошибка.
Вот соответствующий код:

Код: Выделить всё

package com.mycompany.app;

import static org.junit.jupiter.api.Assertions.assertEquals;

import org.junit.jupiter.api.Test;

import java.util.ArrayList;
import java.util.List;
import java.util.stream.Gatherer;

public class AppTest {

@Test
void exploreStreamGatherer() {
Offer grandChildOffer = new Offer("GP1", List.of());
Offer grandChildOffer2 = new Offer("GP1", List.of());
Offer grandChildOffer3 = new Offer("GP2", List.of());
Offer grandChildOffer4 = new Offer("GP3", List.of());
Offer childOffer1 = new Offer("CP1", List.of(grandChildOffer, grandChildOffer4));
Offer childOffer2 = new Offer("CP2", List.of(grandChildOffer2, grandChildOffer3));
Offer offer = new Offer("P1", List.of(childOffer1, childOffer2));

List distinctGrandChildOffers = getAllDistinctGrandChildOffersByProductCode(offer);
assertEquals(3, distinctGrandChildOffers.size()); // Fails, returns 2
}

static List getAllDistinctGrandChildOffersByProductCode(Offer offer) {
return offer.childOffers().stream()
.flatMap(childOffer -> childOffer.childOffers().stream())
.gather(distinctByProductCode())
.toList();
}

public static Gatherer distinctByProductCode() {
return Gatherer.ofSequential(
ArrayList::new,
(state, element, downstream) -> {
if (hasProductWithSameProductCode(state, element)) {
return false;
}
state.add(element);
return true;
},
(state, downstream) -> {
if (!state.isEmpty()) {
state.forEach(downstream::push);
}
}
);
}

private static boolean hasProductWithSameProductCode(List state, Offer element) {
return state.stream().anyMatch(offer -> offer.productCode().equals(element.productCode()));
}
}

record Offer(String productCode, List childOffers) {
}

Полный контекст исходного кода проекта доступен здесь: репозиторий GitHub.
Основная тема:

• Цель — изучить и понять, как API Gatherer работает в Java 22/23, а не просто решить логику «различия по коду продукта».< /p>
• Когда я ожидаю 3 предмета, собиратель возвращает только 2. Если я увеличиваю количество предложений до 4, я получаю 3 предмета, но последний по-прежнему опущен.

Вопросы:

• Что-то мне не хватает в том, как Gatherer API обрабатывает потоки?
• Может ли это быть ошибка в реализации функции предварительной версии, или я ошибаюсь? неправильное использование API?
• Существуют ли какие-либо рекомендации или известные ограничения в отношении Gatherer, которые могли бы объяснить такое поведение?

Подробнее здесь: https://stackoverflow.com/questions/790 ... tem-in-str