为什么对这个java流进行两次操作？

Question

Java8 API说：

Stream<Integer> stream = Stream.of(1,2,3);
stream.filter( x-> x>1 );
stream.filter( x-> x>2 ).forEach(System.out::print);

Answer 1

发生这种情况是因为您忽略了filter的返回值。

Stream<Integer> stream = Stream.of(1,2,3);
stream.filter( x-> x>1 ); // <-- ignoring the return value here
stream.filter( x-> x>2 ).forEach(System.out::print);

stream.filter返回一个新的stream,由该流中与给定谓词匹配的元素组成。但需要注意的是，这是一个新的流。当过滤器被添加到它时，旧的一个已经被操作了。但新的不是。

引用streamJavadoc：

因此这段代码可以正常工作：

Stream<Integer> stream = Stream.of(1,2,3);
stream = stream.filter( x-> x>1 ); // <-- NOT ignoring the return value here
stream.filter( x-> x>2 ).forEach(System.out::print);

正如Brian Goetz所指出的,您通常会将这些调用连接在一起：

Stream.of(1,2,3).filter( x-> x>1 )
                .filter( x-> x>2 )
                .forEach(System.out::print);