Java Streams — 如何对提供的最后一个值执行中间函数

Question

类似这个问题: Java Streams — How to perform an intermediate function every nth item

但是这一次，总是在检索到的最后一个终端值上做一些中间的事情。类似于此:

IntStream.rangeClosed(1, 26)
         .filter(it -> isPrime(it))
         .peek(every(5, System.out::println))
         .onFinalValue( it -> System.out.println("Last value is: " + it))
         .forEach( it -> {});

这样它应该每 5 个值打印一次，但也显示最后一个值。

您可能知道也可能不知道原始流的长度。因此它可能是热的(现场音频、电视视频源)或冷的(预录音频或其他向前/向后可搜索的源)。

Answer 1

因为 count() 是一个终止操作，你需要稍微改变一下你的逻辑:

    int res = IntStream.rangeClosed(1, 26)
            .filter(it -> countIfPrime(it))
            .peek(every(5, System.out::println))
            .reduce(0, (left, right) -> right);

    System.out.println("Final " + res);

在 countIfPrime() 中你也应该增加计数