Stream.limit(n)会返回一个包含n个元素的新流(如果原始流的长度小于n,则会返回原始的流)。例如:
package java8test;import java.util.stream.Stream;public class T2 { public static void main(String[] args) { Stream.generate(Math::random).limit(50).forEach(System.out::println); //注意这句 }}
该示例会产生一个包含50个随机数字的流。又例:
package java8test;import java.util.stream.Stream;public class T2 { public static void main(String[] args) { //注意这句 Stream.of("1","2","3","4","5","6").limit(4).forEach(System.out::println); }}
Stream.skip(n)正好相反,它会丢弃掉前面的n个元素。示例:
package java8test;import java.util.stream.Stream;public class T2 { public static void main(String[] args) { //注意这句 Stream.of("1","2","3","4","5","6").skip(4).forEach(System.out::println); }}
你可以使用Stream类的静态方法concat将两个流连接到一起:
package java8test;import java.util.stream.Stream;public class T2 { public static void main(String[] args) { //注意这句 Stream.concat(Stream.of("1","2","3"), Stream.of("a","b","c")). forEach(System.out::println); }}
当然,第一个流的长度不应该是无限的——否则第二个流就永远没有机会被添加到第一个流的后面。
peek方法会产生另一个与原始流具有相同元素的流,但是在每次获取一个元素时,都会调用一个函数,这样便于调试:
package java8test;import java.util.stream.Stream;public class T2 { public static void main(String[] args) { //注意这句 Stream.iterate(1, p -> p*2).peek(n -> System.out.println("num:" + n)). limit(10).forEach(System.out::println);; }}