java8之Stream API（提取子流和组合流）

Stream.limit(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);;
    }
}