在
scala中,这些方法工作正常,但在
java9中,dropWhile的工作方式与我想的不同.
以下是takeWhile的示例
Stream.of("a","b","c","de","f","g","h")
.peek(System.out::println)
.takeWhile(s -> s.length() <= 1)
.collect(Collectors.toList());
输出很好：
a,b,c,de,[a,c]
它不会在“de”之后处理元素,因此它按预期工作
但是DropWhile以我期望的不同方式工作：
Stream.of("a","h")
.peek(s -> System.out.print(s + ","))
.dropWhile(s -> s.length() <= 1)
.collect(Collectors.toList());
输出是：
a,f,g,h,[de,h]
因此它不会在“de”元素之后停止,它正在处理整个集合.
为什么要处理整个系列？我知道,需要采取所有元素并将其收集到列表中,但不应该在“de”元素之后停止处理吗？
解决方法
看来,对于窥视的工作方式存在根本性的误解.它与下一个后续链接操作(如dropWhile)无关,而是与其后面的整个Stream管道相关联.它并没有区分“处理元素”和“占用所有元素”.
所以简单的代码
Stream.of("a","h")
.peek(System.out::println)
.collect(Collectors.toList());
“获取所有元素”,但在将它们从Stream源传递到收集器时打印它们.
在您的示例中,无论是将元素传递给dropWhile的谓词还是直接传递给收集器都没有区别,在任何一种情况下,它都将通过放在两者之前的peek操作进行报告.
如果你使用
Stream.of("a","h")
.dropWhile(s -> {
System.out.println("dropWhile: "+s);
return s.length() <= 1;
})
.peek(s -> System.out.println("collecting "+s))
.collect(Collectors.toList());
相反,它会打印出来
dropWhile: a dropWhile: b dropWhile: c dropWhile: de collecting de collecting f collecting g collecting h
显示dropWhile的谓词的评估如何在第一个未接受的元素之后停止,而向收集器的传输以该元素开始.
这与takeWhile不同,其中谓词评估和收集器都停止使用元素,因此没有消费者,整个Stream管道可以停止迭代源.