如何在akka流中抛出异常？

import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Flow, Sink, Source}

object AkkaStreamExceptionExample extends App {
  implicit val system = ActorSystem("akka-stream-exception")
  implicit val materializer = ActorMaterializer()

  // 创建一个简单的流
  val stream = Source(1 to 10)
    .via(Flow[Int].map { num =>
      if (num % 2 == 0) {
        throw new RuntimeException("Even number encountered!")
      } else {
        num
      }
    })
    .to(Sink.foreach(println))

  // 运行流并处理异常
  stream.run().recover {
    case ex: RuntimeException =>
      println(s"Exception encountered: ${ex.getMessage}")
  }
}