为什么我的takeWhile无法使用我的Stream

Question

以下代码打印"*1".令人费解的是,如果我删除评论,它会返回"*4",这正是我所期待的

var max = 0
lazy val list: Stream[Int] = 1 #:: Stream.from(2)
list.takeWhile {
  x =>
    max = x
    x < 4
}//.foreach(println)
println("*" + max)

Answer 1

首先:lazy你的第二行没有做任何事情 - 你可以删除它并获得相同的结果.

更重要的是:takeWhile是真正懒惰的,因为它只是返回另一个Stream,直到它的需要没有过去那种流的头部进行评估.考虑以下:

val s = Stream.from(1).takeWhile(_ > 0)

你和我知道这s将是一个无限的流,但是如果我们启动REPL并输入它,那么它非常乐意评估它:

scala> val s = Stream.from(1).takeWhile(_ > 0)
s: scala.collection.immutable.Stream[Int] = Stream(1, ?)

在你的例子中也会发生同样的事情:(Int) ? Boolean你传递给takeWhile它的东西不会被提供给流的头部以外的任何元素,直到像你foreach这样的东西必要时.

通过添加类似谓词println内部的内容,您可以更加显着地看到这一点takeWhile:

scala> val s = Stream.from(1).takeWhile { x => println("Checking: " + x); x < 4 }
Checking: 1
s: scala.collection.immutable.Stream[Int] = Stream(1, ?)

scala> val l = s.toList
Checking: 2
Checking: 3
Checking: 4
l: List[Int] = List(1, 2, 3)

很明显,谓词只会被调用为流的头部,直到我们通过调用强制评估流的其余部分toList.