Java 9 - 流 API 改进

---

Java 中引入了流，以帮助开发人员从一系列对象执行聚合操作。在 Java 9 中，添加了一些方法来使流变得更好。

takeWhile（谓词接口）

句法

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

takeWhile 方法获取所有值，直到谓词返回 false。在有序流的情况下，它返回一个流，该流由从此流中获取的与给定谓词匹配的元素的最长前缀组成。

例子

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

输出

takeWhile 方法获取所有 a、b 和 c 值，然后一旦字符串为空，它就会停止执行。

abc

dropWhile（谓词接口）

句法

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

dropWhile 方法丢弃开始时的所有值，直到谓词返回 true。在有序流的情况下，它在删除与给定谓词匹配的元素的最长前缀后返回由该流的剩余元素组成的流。

例子

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

输出

dropWhile 方法删除 a、b 和 c 值，然后一旦字符串为空，它就会获取所有值。

ef
ef

迭代

句法

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

iterate 方法现在将 hasNext 谓词作为参数，一旦 hasNext 谓词返回 false，该方法就会停止循环。

例子

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

输出

3
6
9

可空的

句法

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

引入 ofNullable 方法是为了防止 NullPointerException 并避免对流进行 null 检查。此方法返回包含单个元素的顺序 Stream，如果非 null，则返回空 Stream。

例子

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

输出

1
0