、
scala> val stream = Stream.continually(1)
stream: scala.collection.immutable.Stream[Int] = Stream(1, ?)
scala> val newStream = stream.take(10).zipWithIndex.map{case (value, index) => { println(s"processing ${index}"); value * 2 } }
processing 0
newStream: scala.collection.immutable.Stream[Int] = Stream(2, ?)
ので、そのチェックを追加するだけではないに最初で初めて
scala> val newStream = stream.take(10).zipWithIndex.map{case (value, index) => { println(s"processing ${index}"); throw new Exception; value * 2 } }
processing 0
java.lang.Exception
at .$anonfun$newStream$1(<console>:12)
at .$anonfun$newStream$1$adapted(<console>:12)
at scala.collection.immutable.Stream.map(Stream.scala:415)
... 29 elided
あなたが確認することができますを評価するために、あなたのケースで例外がスローされます時間は以下の通り
scala> val newStream = stream.take(10).zipWithIndex.map{case (value, index) => { println(s"processing ${index}"); if(index > 0) throw new Exception; value * 2 } }
processing 0
newStream: scala.collection.immutable.Stream[Int] = Stream(2, ?)