Perguntas com a marcação «stream»

162
Como clonar um InputStream?

Eu tenho um InputStream que passo para um método para fazer algum processamento. Usarei o mesmo InputStream em outro método, mas após o primeiro processamento, o InputStream parece ser fechado dentro do método. Como posso clonar o InputStream para enviar para o método que o fecha? Existe outra...

160
É possível transmitir um fluxo no Java 8?

É possível transmitir um fluxo no Java 8? Digamos que eu tenha uma lista de objetos, posso fazer algo assim para filtrar todos os objetos adicionais: Stream.of(objects).filter(c -> c instanceof Client) Após isso, porém, se eu quiser fazer algo com os clientes, precisarei converter cada um...

153
Ordem Reversa do Java 8 Stream

Pergunta geral: Qual é a maneira correta de reverter um fluxo? Supondo que não sabemos em que tipo de elementos esse fluxo consiste, qual é a maneira genérica de reverter qualquer fluxo? Pergunta específica: IntStreamfornece o método range para gerar números inteiros em um intervalo específico...

148
Como garantir a ordem de processamento nos fluxos java8?

Eu quero processar listas dentro de um XMLobjeto java. Eu tenho que garantir o processamento de todos os elementos para que eu os receba. Devo, portanto, chamar sequentialcada um que streameu uso? list.stream().sequential().filter().forEach() Ou é suficiente apenas usar o fluxo, desde que eu não...

147
É possível ler de um InputStream com um tempo limite?

Especificamente, o problema é escrever um método como este: int maybeRead(InputStream in, long timeout) onde o valor de retorno é o mesmo que in.read () se os dados estiverem disponíveis dentro de 'timeout' milissegundos e -2 caso contrário. Antes do método retornar, todos os threads gerados...

146
Você pode dividir um fluxo em dois fluxos?

Eu tenho um conjunto de dados representado por um fluxo Java 8: Stream<T> stream = ...; Eu posso ver como filtrá-lo para obter um subconjunto aleatório - por exemplo Random r = new Random(); PrimitiveIterator.OfInt coin = r.ints(0, 2).iterator(); Stream<T> heads = stream.filter((x)...

143
Java 8 Streams - coletar vs reduzir

Quando você usaria collect()vs reduce()? Alguém tem exemplos bons e concretos de quando é definitivamente melhor seguir um caminho ou outro? Javadoc menciona que collect () é uma redução mutável . Dado que é uma redução mutável, presumo que exija sincronização (internamente), o que, por sua vez,...