English | 简体中文 | 繁體中文 | Русский язык | Français | Español | Português | Deutsch | 日本語 | 한국어 | Italiano | بالعربية
Java 9 A API de Stream melhorada adicionou alguns métodos convenientes, tornando o processamento de fluxo mais fácil e permitindo a escrita de consultas complexas com coletores.
Java 9 Foram adicionados vários métodos para Stream: dropWhile, takeWhile, ofNullable, e foi adicionado um método sobrecarregado para o método iterate.
Sintaxe
default Stream<T> takeWhile(Predicate<? super T> predicate)
O método takeWhile() usa uma afirmação como parâmetro, retornando um subconjunto do Stream dado até que a afirmação retorne false pela primeira vez. Se o primeiro valor não atender à condição da afirmação, será retornado um Stream vazio.
O método takeWhile() retorna o maior número possível de elementos do início em um Stream ordenado; em um Stream não ordenado, takeWhile() retorna um subconjunto dos elementos que atendem ao Predicate no início.
import java.util.stream.Stream; public class Tester { public static void main(String[] args) { Stream.of("a","b","c","","e","f").takeWhile(s->!s.isEmpty()) .forEach(System.out::print); } }
O exemplo acima do método takeWhile para de emitir valores em loop quando encontra uma string vazia, e o resultado da execução é:
abc
Sintaxe
default Stream<T> dropWhile(Predicate<? super T> predicate)
O método dropWhile e o takeWhile são opostos, usando uma afirmação como parâmetro até que a afirmação retorne false pela primeira vez, retornando assim um subconjunto do Stream dado.
import java.util.stream.Stream; public class Tester { public static void main(String[] args) { Stream.of("a","b","c","","e","f").dropWhile(s-> !s.isEmpty()) .forEach(System.out::print); } }
O exemplo acima do método dropWhile começa a emitir valores em loop quando encontra uma string vazia, e o resultado da execução é:
ef
Sintaxe
static <T> Stream<T> iterate(T seed, Predicate<? super T> hasNext, UnaryOperator<T> next)
O método permite usar um valor de semente inicial para criar um fluxo sequencial (pode ser infinito) e iterar aplicando o método especificado subsequente. A iteração termina quando o predicate especificado hasNext retorna false.
java.util.stream.IntStream; public class Tester { public static void main(String[] args) { IntStream.iterate(3, x -> x < 10, x -> x+ 3).forEach(System.out::println); } }
O resultado da execução é:
3 6 9
Sintaxe
static <T> Stream<T> ofNullable(T t)
O método ofNullable pode prevenir exceções NullPointerExceptions, evitando valores null através da verificação do fluxo.
Se o elemento especificado não for null, obtem um elemento e gera um fluxo de um único elemento, se o elemento for null, retorna um fluxo vazio.
import java.util.stream.Stream; public class Tester { public static void main(String[] args) { long count = Stream.ofNullable(10).count(); System.out.println(count); count = Stream.ofNullable(null).count(); System.out.println(count); } }
O resultado da execução é:
1 0