Kotlin Stream peek(.)方法

Question

Kotlin对java.util.stream.Stream<>.peek的最佳选择是什么(.)？

https://docs.oracle.com/javase/8/docs/api/java/util/stream/Stream.html#peek-java.util.function.Consumer-

似乎没有替代的中间操作：

https://kotlinlang.org/api/latest/jvm/stdlib/kotlin.streams/index.html

我发现只有终止forEach(.)

Answer 1

Kotlin的Stream是序列。

 listOf(1, 2, 3, 4, 5)
    .asSequence()
    .filter { it < 3 }
    .onEach { println("filtered $it") }
    .map { it * 10 }
    .forEach { println("final: $it") }

onEach可以做peek所做的事情。

有趣的事实：Kotlin还想在Java做同样的事情之前把它们的序列称为"Streams“，所以他们把它重命名为”Sequence“。

Answer 2

首先，与Kotlin中的Java不同，您可以对任何类型的集合执行流处理(map/还原操作)，例如：

val list = ArrayList<Int>()
list.forEach {  }
list.onEach {  } 

但是，以这种方式定义的操作不会被延迟计算，如果需要，则通过应用.asSequence()方法并从集合生成流来进行惰性评估。

最后，要回答您的问题，onEach()相当于peek()