Resultados da pesquisa a pedido "java-stream"
Por que o tryAdvance do stream.spliterator () pode acumular itens em um buffer?
Obtendo umSpliterator a partir de umStream pipeline pode retornar uma instância de ...
Alternativa para o throwingMerger em Java 8
Estou implementando coletor próprio que usafunção de mesclagem. Infelizmente, em alguns casos, não posso reutilizar a seguinte função de fusão do JDK que lançou IllegalStateException. java.util.stream.Collectors#throwingMergerIsso acontece ...
Como atualizar cada elemento em uma lista no Java 8 usando a API de fluxo
Eu tenho uma lista definida da seguinte maneira: List<Integer> list1 = new ArrayList<>(); list1.add(1); list1.add(2);Como posso incrementar cada elemento da lista em um (ou seja, acabar com uma lista[2,3]) usando a API Stream do Java 8 sem criar ...
Os fluxos Java findAny () encontram uma exceção de ponteiro nulo após a operação filter () filtrar tudo
Estou tendo problemas para entender por quefindAny() lança uma exceção de ponteiro nulo apósfilter() operação em um fluxo. Nesse caso de teste específico, a operação de filtro deve ter filtrado tudo, não deixando ...
Java 8 Streams - Tempo limite?
Quero fazer um loop em uma enorme variedade e executar um conjunto complicado de instruções que leva muito tempo. No entanto, se tiverem passado mais de 30 segundos, quero que desista. ex. final long start = System.currentTimeMillis(); ...
Use parallelStream foreach para criar HashMap, mas às vezes o valor está vazio
Como código Java: List<Detail> DbDetails = ... Like 50000 rows records Map<Long, List<Detail>> details = new HashMap(); DbDetails .parallelStream().forEach(detail -> { Long id = detail.getId(); details.computeIfAbsent(id, v -> ...
Como converter forEach para lambda
Iterator<Rate> rateIt = rates.iterator(); int lastRateOBP = 0; while (rateIt.hasNext()) { Rate rate = rateIt.next(); int currentOBP = rate.getPersonCount(); if (currentOBP == lastRateOBP) { rateIt.remove(); continue; } lastRateOBP = currentOBP; ...
Quando um Java 8 Stream é considerado consumido?
Meu entendimento era que um Java 8Stream é considerado consumido uma vez que uma operação do terminal, comoforEach() oucount(), é realizado. No entanto, o caso de testemultipleFilters_separate abaixo lança umIllegalStateException Apesar defilter ...
Fluxo versus Iterador na entradaConjunto de um mapa
Para meu entendimento, o seguinte código deve ser impressotrue, já que ambosStream eIterator estão apontando para o primeiro elemento. No entanto, quando executo o código a seguir, ele está imprimindofalse: final HashMap<String, String> map = ...
Requisito de Não Interferência nos Fluxos Java 8
Eu sou iniciante em Java 8. A não interferência é importante para ter um comportamento consistente do fluxo Java. Imagine que estamos processando um grande fluxo de dados e, durante o processo, a fonte é alterada. O resultado será imprevisível. ...