Java 9 - Melhorias na API de fluxo

Streams foram introduzidos em Java para ajudar os desenvolvedores a realizar operações de agregação de uma sequência de objetos. Com o Java 9, mais alguns métodos são adicionados para tornar os fluxos melhores.

takeWhile (interface de predicado)

Sintaxe

default Stream<T> takeWhile(Predicate<? super T> predicate)

O método takeWhile leva todos os valores até que o predicado retorne falso. Ele retorna, no caso de fluxo ordenado, um fluxo que consiste no prefixo mais longo de elementos retirados desse fluxo correspondendo ao predicado fornecido.

Exemplo

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);		 
   } 
}

Resultado

O método takeWhile assume todos os valores a, b e c e, quando a string está vazia, a execução é interrompida.

abc

dropWhile (interface de predicado)

Sintaxe

default Stream<T> dropWhile(Predicate<? super T> predicate)

O método dropWhile descarta todos os valores no início até que o predicado retorne verdadeiro. Ele retorna, no caso de fluxo ordenado, um fluxo que consiste nos elementos restantes deste fluxo após descartar o prefixo mais longo de elementos correspondentes ao predicado fornecido.

Exemplo

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);
      
      System.out.println();
      Stream.of("a","b","c","","e","","f").dropWhile(s-> !s.isEmpty())
         .forEach(System.out::print);
   } 
}

Resultado

O método dropWhile elimina os valores a, bec, então, quando a string está vazia, ele pega todos os valores.

ef
ef

iterar

Sintaxe

static <T> Stream<T> iterate(T seed, Predicate<? super T> hasNext, UnaryOperator<T> next)

O método iterate agora tem o predicado hasNext como parâmetro que interrompe o loop quando o predicado hasNext retorna falso.

Exemplo

import 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);
   } 
}

Resultado

3
6
9

ofNullable

Sintaxe

static <T> Stream<T> ofNullable(T t)

O método ofNullable é introduzido para evitar NullPointerExceptions e para evitar verificações de nulos para fluxos. Este método retorna um Stream sequencial contendo um único elemento, se não nulo, caso contrário, retorna um Stream vazio.

Exemplo

import java.util.stream.Stream;

public class Tester {
   public static void main(String[] args) {
      long count = Stream.ofNullable(100).count();
      System.out.println(count);
  
      count = Stream.ofNullable(null).count();
      System.out.println(count);
   } 
}

Resultado

1
0