Java流中的中间操作[复制]

理想情况下,您不应该改变外部列表,而是可以使用 Collectors.toList() 要将其收集到列表中,请执行以下操作:

List<String> list = stream.peek(System.out::println)
            .filter(p1.or(p2))
            .collect(Collectors.toList()); // triggers the evaluation of the stream
System.out.println("Size = "+list.size());

在你的例子中, 只有在终端操作时才计算流 喜欢

allMatch()
anyMatch() 
noneMatch() 
collect() 
count() 
forEach() 
min() 
max() 
reduce()

遇到。

因为您还没有完成流操作,即 peek 是一个中间操作。必须使用 终端操作 为了让这件事仍能执行。

建议 :相反,使用终端操作执行此类操作,例如 collect

List<String> list = stream.peek(System.out::println)
        .filter(p1.or(p2))
        .collect(Collectors.toList());

另外:添加 偷看 邮递 filter 观察这些值在观察中可能有点困难,如下面的代码

List<String> list = stream.peek(System.out::println)
        .filter(p1.or(p2))
        .peek(System.out::println) // addition
        .collect(Collectors.toList());

输出如下:

one
two
two // filtered in
three
three // filtered in
four
five

小溪很懒。你必须像 forEach :

stream.peek(System.out::println)
      .filter(p1.or(p2))
      .forEach(list::add);

万一你想用 peek 作为调试的中间操作,之后必须调用终端操作:

stream.peek(System.out::println)
      .filter(p1.or(p2))
      .peek(list::add);
      .<any terminal operation here>();

顺便说一句,如果您只想将所有过滤后的值存储在一个列表中,那么最好使用 collect(toList()) .

你所做的一切 filter 和 peek 设置应用于流的操作链。实际上你还没有让他们跑过。您必须添加终端操作,例如 count . (另一个答案建议使用 forEach 要添加到列表中,但我认为您正在特别尝试使用中间操作 偷看 )