“Stream.take”的奇怪行为

Question

我正在尝试scala.Stream的一些方法，并定义了这样一个方法:

def my(n: Int) = {
  scala.Stream.from(1).flatMap { i =>
    println("### " + i)
    scala.Stream.from(i).takeWhile(_ < 10).map(j => (i, j))
  }.take(n).filter(x => x._1 < 3 && x._2 < 5).toList
}

如果我给n一个数字45:

println(my(45))

终止非常快，并打印:

### 1
### 2
### 3
### 4
### 5
### 6
### 7
### 8
### 9
List((1,1), (1,2), (1,3), (1,4), (2,2), (2,3), (2,4))

但如果n是46，它将永远不会结束:

### 1
### 2
### 3
### 4
### 5
### 6
...
### 245684
### 245685
### 245686
### 245687
### 245688
### 245689
### 245690
### 245691
...

为什么这么奇怪?

PS:我的scala版本是2.11.7

Answer 1

平面映射结果中的第45项是(9,9)。这是最后一个可以从数字i <10. 因此，为了生成第46个元组，接下来的代码尝试i = 10，但Stream.from(i).takeWhile(_ < 10)没有返回有效的元组，因此代码立即移动到i = 11，以此类推，给出您看到的打印行，但从未为流生成新元素…