Как в Stream получить объект из предыдущего шага?

Question

[Jake Taylor]

Имеется метод в ДАО слое. В методе составляется запрос с помощь CriteriaBuilder. В данный метод в качестве аргумента приходит Map<ColumnName, SqlSortOperator> params:

@Override
    public Set<GiftCertificate> findAllOrderBy(Map<ColumnName, SqlSortOperator> params) {
        CriteriaBuilder cb = entityManager.getCriteriaBuilder();
        CriteriaQuery<GiftCertificate> cq = cb.createQuery(GiftCertificate.class);
        Root<GiftCertificate> from = cq.from(GiftCertificate.class);
        // work with Stream....
}

Сделал работу с Map следующим образом:

Set<Order> orders = new HashSet<>();        
for(Map.Entry<ColumnName, SqlSortOperator> entry : params.entrySet()) {
    String field = entry.getKey().name().toLowerCase();
    Path<String> path = from.get(field);

    SqlSortOperator sqlSortOperator = entry.getValue();
    Order order = sqlSortOperator.equals(SqlSortOperator.ASC) ? cb.asc(path) : cb.desc(path);            
    orderSet.add(order);
}

Выглядит громоздко, решил переписать с использованием Stream, но столкнулся с моментом - Как в Stream получить объект из предыдущего шага:

Set<Order> orders = params.entrySet().stream()
                .map(Map.Entry::getKey)
                .map(Enum::name)
                .map(String::toLowerCase)   // String columnName = "name"
                .map(from::get) // Path<String> path = from.get(columnName);
                .map() // Как выполнить SqlSortOperator sqlSortOperator = entry.getValue();
                .map() // Order order = sqlSortOperator.equals(SqlSortOperator.ASC) ? cb.asc(path) : cb.desc(path); 
                .collect(Collectors.toSet());

Answer 1

[Jake Taylor]

Вот пример. Получить можно объект из любого предыдущего шага. Для этого нужно открыть новый Stream.of() внутрти текущего стрима:

return orderDao.findUsersWithHighestCostOfAllOrders().stream()
                .flatMap(up -> Stream.of(up)
                        .map(UserPrice::getUser)
                        .map(this::findAllGiftCertificatesByUser)
                        .map(this::findAllTagsFromGiftCertificates)
                        .map(this::findCountOfRepetitionsOfEachTag)
                        .map(map -> buildMostWidelyUsedTag(up, map)))
                .collect(Collectors.toSet());

Answer 2

[Dmitry Roo]

Никак. Надо искать другое решение.

Comments

[Jake Taylor]

Спасибо, Dmitry Roo, Какие есть варианты?

[Dmitry Roo]

Jake Taylor, а что вы хотите получить в итоге?

[Jake Taylor]

Dmitry Roo, Хочу получить список из javax.persistence.criteria.Order. Я в топике реализовал то, как хотел, только хочу сделать это уже с помощью Stream.

Set<Order> orders = new HashSet<>();        
for(Map.Entry<ColumnName, SqlSortOperator> entry : params.entrySet()) {
    String field = entry.getKey().name().toLowerCase();
    Path<String> path = from.get(field);

    SqlSortOperator sqlSortOperator = entry.getValue();
    Order order = sqlSortOperator.equals(SqlSortOperator.ASC) ? cb.asc(path) : cb.desc(path);            
    orderSet.add(order);
}

[Dmitry Roo]

Jake Taylor, отсортированный список просто?

[Jake Taylor]

Dmitry Roo, Да

[Dmitry Roo]

Jake Taylor, используйте .sorted( (a, b) -> ...