public class Demo1 {

    public static void main(String[] args) {

        new Random(47)

//       ints() 方法产生一个流并且 ints() 方法有多种方式的重载

//      — 两个参数限定了数值产生的边界。这将生成一个整数流

                .ints(5,60)

                .distinct()//distinct() 来获取它们的非重复值

                .limit(7)//使用 limit() 方法获取前 7 个元素

                .sorted()//使用 sorted() 方法排序

//                forEach() 方法遍历输出，它根据传递给它的函数对每个

//                流对象执行操作。

                .forEach(System.out::println);

//        我们传递了一个可以在控制台显示每个元素的方法引用。System.out::println

    }

}

创建流

public class BuildUp {

    public static void main(String[] args) {

        Stream.of("aaa","bbb","vvv").forEach(System.out::print);

        Stream.of(1111,2222,3333).forEach(System.out::print);

        //从 Map 集合中产生流数据，。然后分别调用 getKey() 和 getValue() 获取值。

        Map<String,Double> m = new HashMap<>();

        m.put("AA",1.1);

        m.put("BB",1.3);

        m.put("DDD",3.1);

        m.put("CCC",2.1);

//我们首先调用 entrySet() 产生一个对象流，每个对象都包含一个 key 键以及与其相关联的 value 值

//        将对象作为e参数传到后面，

        m.entrySet().stream().map(e -> e.getKey()+":"+

                e.getValue()).forEach(System.out::println);

    }

}

/*

Supplier 接口有一个方法就是get

 */

public class Generate implements Supplier<String>{

    Random rand = new Random(47);

    char[] letters = "ABCDEFGHIJK".toCharArray();

//    重写接口中的函数，返回String类型值

    public String get(){

//        在指定的数组里面挑选字母

//        Random.nextInt() 的参数代表可以接受的最大的随机数范围

        return "" + letters[rand.nextInt(letters.length)];

    }

    public static void main(String[] args) {

        String  word = Stream.generate(new Generate()).limit(20)

                .collect(Collectors.joining());

        System.out.println(word);

        System.out.println("#######################");

        Stream.generate(() -> "done").limit(3)

                .forEach(System.out::println);

    }

}

public class Fibonacci {

    int x =1;

//    匿名函数

    Stream<Integer> numbers(){

//        lambada表达式的函数

        return Stream.iterate(0,i ->{

            int result = x +i;

            x = i;

            return result;

        });

    }

    public static void main(String[] args) {

        new Fibonacci().numbers()

                .skip(10)

                .limit(10)

                .forEach(System.out::println);

    }

}

/*

斐波那契数列就是签两个数相加得到写一个元素

55

89

144

233

377

610

987

1597

2584

418

 */

public class FileTo {

//    建立构建器，builder

    Stream.Builder<String> builder = Stream.builder();

    public FileTo(String fp) throws Exception{

        Files.lines(Paths.get(fp))

                .skip(1)

//

                .forEach(line ->{for (String w:line.split("[ .?,]+"))//以上面做分割

                    builder.add(w);//分割完的部分加入流构建器里面

                });

    }

    Stream<String> stream(){

        return builder.build();

    }

    public static void main(String[] args) throws Exception {

//        实例化流对象

        new FileTo("src/flow/FileTo.java")

                .stream()

                .limit(7)

                .map(w -> w +" ")

                .forEach(System.out::print);

    }

}

/*

 import java nio file Files; import

 */

public class Demo2 {

    public static void main(String[] args) {

        ArrayList<String> list = new ArrayList<>();

        list.add("AAA");

        list.add("BBB");

        list.add("CCC");

        list.add("DDD");

        list.add("EEE");

        System.out.println(list);

        list.stream().forEach(System.out::println);

    }

}

public class IntLongDouble {

    public static void main(String[] args) {

//        int stream

        Arrays.stream(new int[] {1,2,3,4,5})

                .forEach(n -> System.out.format("%d  ",n));//lamabad表达式

        System.out.println();

        System.out.println("#######################");

        //指定从哪里开始到哪里结束，左闭右开区间

        Arrays.stream(new double[] {1.1,2.2,3.3,4.4,5.5,6.6,7.7},3,6)

                .forEach(n -> System.out.println(n));

        System.out.println("##############");

        Arrays.stream(new long[] {111111,444444,444999})

                .forEach(System.out::println);//引用

    }

}